File tree Expand file tree Collapse file tree 1 file changed +13
-4
lines changed Expand file tree Collapse file tree 1 file changed +13
-4
lines changed Original file line number Diff line number Diff line change @@ -42,22 +42,31 @@ def _get_dsm_context_from_sqs_lambda(message):
4242 context_json = None
4343 message_attributes = message .get ("messageAttributes" )
4444 if not message_attributes :
45- logger .debug ("DataStreams skipped lambda message: %r" , message )
45+ logger .debug (
46+ "DataStreams skipped lambda message: %r, no messageAttributes" , message
47+ )
4648 return None
4749
4850 if "_datadog" not in message_attributes :
49- logger .debug ("DataStreams skipped lambda message: %r" , message )
51+ logger .debug (
52+ "DataStreams skipped lambda message: %r, no datadog context" , message
53+ )
5054 return None
5155
5256 datadog_attr = message_attributes ["_datadog" ]
5357
5458 if "stringValue" in datadog_attr :
5559 context_json = json .loads (datadog_attr ["stringValue" ])
5660 if not isinstance (context_json , dict ):
57- logger .debug ("DataStreams did not handle lambda message: %r" , message )
61+ logger .debug (
62+ "DataStreams did not handle lambda message: %r, context is not a dict" ,
63+ message ,
64+ )
5865 return None
5966 else :
60- logger .debug ("DataStreams did not handle lambda message: %r" , message )
67+ logger .debug (
68+ "DataStreams did not handle lambda message: %r, no dsm context" , message
69+ )
6170
6271 return context_json
6372
You can’t perform that action at this time.
0 commit comments