Add cluster name

Author: PandaXass

example-deployment.yaml

@@ -16,23 +16,25 @@ spec:
         imagePullPolicy: Always
         name: k8s-events-streamer
         env:
-#        - name: K8S_EVENTS_STREAMER_INCOMING_WEB_HOOK_URL
-#          value: PUT-WEB-HOOK-URL-HERE
+        - name: K8S_EVENTS_STREAMER_CLUSTER_NAME
+          value: my-cluster
+        - name: K8S_EVENTS_STREAMER_INCOMING_WEB_HOOK_URL
+          value: PUT-WEB-HOOK-URL-HERE
         - name: K8S_EVENTS_STREAMER_AWS_REGION
           value: 'us-east-1'
         - name: K8S_EVENTS_STREAMER_CW_LOG_GROUP
           value: PUT-CW-LOG-GROUP-NAME-HERE
         - name: K8S_EVENTS_STREAMER_NAMESPACE
           value: 'default'
-#        - name: K8S_EVENTS_STREAMER_DEBUG
-#          value: 'true'
+        - name: K8S_EVENTS_STREAMER_DEBUG
+          value: 'true'
         - name: K8S_EVENTS_STREAMER_SKIP_DELETE_EVENTS
           value: 'True'
-#        It is imporatnt that you use <> around user names
-#        https://api.slack.com/docs/message-formatting#linking_to_channels_and_users
-#        - name: K8S_EVENTS_STREAMER_USERS_TO_NOTIFY
-#          value: '<@andrey9kin>'
-        # - name: K8S_EVENTS_STREAMER_LIST_OF_REASONS_TO_SKIP
-        #   value: 'Scheduled ScalingReplicaSet Pulling Pulled Created Started Killing SuccessfulMountVolume SuccessfulUnMountVolume'
+        #  It is imporatnt that you use <> around user names
+        #  https://api.slack.com/docs/message-formatting#linking_to_channels_and_users
+        - name: K8S_EVENTS_STREAMER_USERS_TO_NOTIFY
+          value: '<@andrey9kin>'
+        - name: K8S_EVENTS_STREAMER_LIST_OF_REASONS_TO_SKIP
+          value: 'Scheduled ScalingReplicaSet Pulling Pulled Created Started Killing SuccessfulMountVolume SuccessfulUnMountVolume'
         - name: K8S_EVENTS_STREAMER_LIST_OF_REASONS_TO_INCLUDE
           value: 'SuccessfulRescale'

k8s-events-streamer.py

@@ -43,12 +43,12 @@ def is_reason_in_include_list(event, include_list):
     return True if event['object'].reason in include_list else False
 
 
-def format_k8s_event_to_slack_message(event_object, notify=''):
+def format_k8s_event_to_slack_message(event_object, cluster_name, notify=''):
     event = event_object['object']
     message = {
         'attachments': [{
             'color': '#36a64f',
-            'title': event.message,
+            'title': '[{}] {}'.format(cluster_name, event.message),
             'text': 'event type: {}, event reason: {}'.format(event_object['type'], event.reason),
             'footer': 'First time seen: {}, Last time seen: {}, Count: {}'.format(event.first_timestamp.strftime('%d/%m/%Y %H:%M:%S %Z'),
                                                                                   event.last_timestamp.strftime(
@@ -90,6 +90,8 @@ def main():
         logging.basicConfig(stream=sys.stdout, level=logging.INFO)
 
     logger.info("Reading configuration...")
+    k8s_cluster_name = read_env_variable_or_die(
+        'K8S_EVENTS_STREAMER_CLUSTER_NAME')
     aws_region = os.environ.get('K8S_EVENTS_STREAMER_AWS_REGION', 'us-east-1')
     k8s_namespace_name = os.environ.get(
         'K8S_EVENTS_STREAMER_NAMESPACE', 'default')
@@ -169,7 +171,7 @@ def main():
 
             if slack_web_hook_url:
                 message = format_k8s_event_to_slack_message(
-                    event, users_to_notify)
+                    event, k8s_cluster_name, users_to_notify)
                 post_slack_message(slack_web_hook_url, message)
         logger.info('No more events. Wait 30 sec and check again')
         time.sleep(30)