Skip to content

Commit 7d1753f

Browse files
committed
Simplify SQS/SNS data extraction logic.
1 parent 0969236 commit 7d1753f

File tree

1 file changed

+3
-9
lines changed

1 file changed

+3
-9
lines changed

datadog_lambda/tracing.py

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -253,19 +253,13 @@ def extract_context_from_sqs_or_sns_event_or_context(event, lambda_context):
253253
# SQS uses dataType and binaryValue/stringValue
254254
# SNS uses Type and Value
255255
dd_json_data = None
256-
dd_json_data_type = dd_payload.get("Type")
257-
if dd_json_data_type is None:
258-
dd_json_data_type = dd_payload.get("dataType")
256+
dd_json_data_type = dd_payload.get("Type") or dd_payload.get("dataType")
259257
if dd_json_data_type == "Binary":
260-
dd_json_data = dd_payload.get("binaryValue")
261-
if dd_json_data is None:
262-
dd_json_data = dd_payload.get("Value")
258+
dd_json_data = dd_payload.get("binaryValue") or dd_payload.get("Value")
263259
if dd_json_data:
264260
dd_json_data = base64.b64decode(dd_json_data)
265261
elif dd_json_data_type == "String":
266-
dd_json_data = dd_payload.get("stringValue")
267-
if dd_json_data is None:
268-
dd_json_data = dd_payload.get("Value")
262+
dd_json_data = dd_payload.get("stringValue") or dd_payload.get("Value")
269263
else:
270264
logger.debug(
271265
"Datadog Lambda Python only supports extracting trace"

0 commit comments

Comments
 (0)