WCM-690: Record event type and uuid for tracing in webhooks (brightco…

…ve, simplecast, speechbert)

core/docs/changelog/WCM-690.change

@@ -0,0 +1 @@
+WCM-690: Record event type and uuid for tracing in webhooks (brightcove, simplecast, speechbert)

core/src/zeit/brightcove/json/update.py

@@ -34,6 +34,9 @@ def __call__(self):
         data = json.loads(body)
         if data.get('event') != 'video-change' or not data.get('video'):
             return
+        current_span.set_attributes(
+            {'app.event_type': data['event'], 'app.external_id': data['video']}
+        )
 
         own_apikey = zeit.cms.config.required('zeit.brightcove', 'client-email')
         origin = data.get('updated_by', {})

core/src/zeit/simplecast/json/webhook.py

@@ -35,7 +35,13 @@ def __call__(self):
         self.execute_task(data)
 
         current_span = opentelemetry.trace.get_current_span()
-        current_span.set_attributes({'http.body': body})
+        current_span.set_attributes(
+            {
+                'http.body': body,
+                'app.event_type': data.get('event', ''),
+                'app.external_id': data.get('episode_id'),
+            }
+        )
 
     def execute_task(self, data: dict):
         SIMPLECAST_WEBHOOK_TASK.delay(data, _principal_id_=self._principal)

core/src/zeit/speech/json/webhook.py

@@ -46,6 +46,13 @@ def __call__(self):
         except InvalidSpeechMessageError as e:
             self.request.response.setStatus(400, e)
             return
+        current_span.set_attributes(
+            {
+                'app.event_type': payload['event'],
+                'app.uuid': payload.get('uuid') or payload.get('article_uuid'),
+            }
+        )
+
         self.execute_task(payload)
 
     def execute_task(self, payload: dict):