Skip to content

Commit 99c0b48

Browse files
nhulstonnhulston
authored
Add DynamoDB Downstream Span Pointers (#600)
1 parent c4f0e65 commit 99c0b48

File tree

117 files changed

+4996
-13
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

117 files changed

+4996
-13
lines changed

‎integration_tests/input_events/dynamodb-one-key-table.json

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
{
2+
"Records": [
3+
{
4+
"eventID": "0123456789abcdef09123456789abcdef",
5+
"eventName": "MODIFY",
6+
"eventVersion": "1.1",
7+
"eventSource": "aws:dynamodb",
8+
"awsRegion": "us-east-1",
9+
"dynamodb": {
10+
"ApproximateCreationDateTime": 1734555118,
11+
"Keys": {
12+
"someKeyColumnName": {
13+
"S": "someValue"
14+
}
15+
},
16+
"SequenceNumber": "123456789012345678901234567",
17+
"SizeBytes": 37,
18+
"StreamViewType": "KEYS_ONLY"
19+
},
20+
"eventSourceARN": "arn:aws:dynamodb:us-east-1:1234567890:table/someTableName/stream/2024-12-11T20:00:00.000"
21+
}
22+
]
23+
}

‎integration_tests/input_events/dynamodb-remove.json

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
{
2+
"Records": [
3+
{
4+
"eventID": "0123456789abcdef09123456789abcdef",
5+
"eventName": "REMOVE",
6+
"eventVersion": "1.1",
7+
"eventSource": "aws:dynamodb",
8+
"awsRegion": "us-east-1",
9+
"dynamodb": {
10+
"ApproximateCreationDateTime": 1734555118,
11+
"Keys": {
12+
"someKeyColumnName": {
13+
"S": "someValue"
14+
}
15+
},
16+
"SequenceNumber": "123456789012345678901234567",
17+
"SizeBytes": 37,
18+
"StreamViewType": "KEYS_ONLY"
19+
},
20+
"eventSourceARN": "arn:aws:dynamodb:us-east-1:1234567890:table/someTableName/stream/2024-12-11T20:00:00.000"
21+
}
22+
]
23+
}

‎integration_tests/input_events/dynamodb-two-key-table.json

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
{
2+
"Records": [
3+
{
4+
"eventID": "0123456789abcdef09123456789abcdef",
5+
"eventName": "INSERT",
6+
"eventVersion": "1.1",
7+
"eventSource": "aws:dynamodb",
8+
"awsRegion": "us-east-1",
9+
"dynamodb": {
10+
"ApproximateCreationDateTime": 1734555118,
11+
"Keys": {
12+
"someKeyColumnName": {
13+
"S": "someValue"
14+
},
15+
"anotherKeyColumnName": {
16+
"S": "anotherValue"
17+
}
18+
},
19+
"SequenceNumber": "123456789012345678901234567",
20+
"SizeBytes": 37,
21+
"StreamViewType": "KEYS_ONLY"
22+
},
23+
"eventSourceARN": "arn:aws:dynamodb:us-east-1:1234567890:table/someTableName/stream/2024-12-11T20:00:00.000"
24+
}
25+
]
26+
}

‎integration_tests/snapshots/logs/async-metrics_node16.log

Lines changed: 86 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11

22
START
3-
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed APIGateway request
43
{
54
"e": XXXX,
65
"m": "aws.lambda.enhanced.invocations",
@@ -26,6 +25,7 @@ XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed APIGat
2625
],
2726
"v": 1
2827
}
28+
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed APIGateway request
2929
{
3030
"e": XXXX,
3131
"m": "serverless.integration_test.execution",
@@ -38,6 +38,34 @@ XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed APIGat
3838
}
3939
END Duration: XXXX ms (init: XXXX ms) Memory Used: XXXX MB
4040
START
41+
{
42+
"e": XXXX,
43+
"m": "aws.lambda.enhanced.invocations",
44+
"t": [
45+
"region:eu-west-1",
46+
"account_id:XXXX",
47+
"functionname:integration-tests-js-XXXX-async-metrics_node16",
48+
"resource:integration-tests-js-XXXX-async-metrics_node16",
49+
"memorysize:1024",
50+
"cold_start:false",
51+
"datadog_lambda:vX.X.X",
52+
"runtime:nodejs16.x"
53+
],
54+
"v": 1
55+
}
56+
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
57+
{
58+
"e": XXXX,
59+
"m": "serverless.integration_test.execution",
60+
"t": [
61+
"tagkey:tagvalue",
62+
"eventsource:undefined",
63+
"dd_lambda_layer:datadog-nodev16.XX.X"
64+
],
65+
"v": 1
66+
}
67+
END Duration: XXXX ms Memory Used: XXXX MB
68+
START
4169
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
4270
{
4371
"e": XXXX,
@@ -66,6 +94,7 @@ XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefi
6694
}
6795
END Duration: XXXX ms Memory Used: XXXX MB
6896
START
97+
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
6998
{
7099
"e": XXXX,
71100
"m": "aws.lambda.enhanced.invocations",
@@ -81,7 +110,34 @@ START
81110
],
82111
"v": 1
83112
}
113+
{
114+
"e": XXXX,
115+
"m": "serverless.integration_test.execution",
116+
"t": [
117+
"tagkey:tagvalue",
118+
"eventsource:undefined",
119+
"dd_lambda_layer:datadog-nodev16.XX.X"
120+
],
121+
"v": 1
122+
}
123+
END Duration: XXXX ms Memory Used: XXXX MB
124+
START
84125
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
126+
{
127+
"e": XXXX,
128+
"m": "aws.lambda.enhanced.invocations",
129+
"t": [
130+
"region:eu-west-1",
131+
"account_id:XXXX",
132+
"functionname:integration-tests-js-XXXX-async-metrics_node16",
133+
"resource:integration-tests-js-XXXX-async-metrics_node16",
134+
"memorysize:1024",
135+
"cold_start:false",
136+
"datadog_lambda:vX.X.X",
137+
"runtime:nodejs16.x"
138+
],
139+
"v": 1
140+
}
85141
{
86142
"e": XXXX,
87143
"m": "serverless.integration_test.execution",
@@ -94,6 +150,7 @@ XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefi
94150
}
95151
END Duration: XXXX ms Memory Used: XXXX MB
96152
START
153+
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
97154
{
98155
"e": XXXX,
99156
"m": "aws.lambda.enhanced.invocations",
@@ -119,7 +176,34 @@ START
119176
],
120177
"v": 1
121178
}
179+
END Duration: XXXX ms Memory Used: XXXX MB
180+
START
122181
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
182+
{
183+
"e": XXXX,
184+
"m": "aws.lambda.enhanced.invocations",
185+
"t": [
186+
"region:eu-west-1",
187+
"account_id:XXXX",
188+
"functionname:integration-tests-js-XXXX-async-metrics_node16",
189+
"resource:integration-tests-js-XXXX-async-metrics_node16",
190+
"memorysize:1024",
191+
"cold_start:false",
192+
"datadog_lambda:vX.X.X",
193+
"runtime:nodejs16.x"
194+
],
195+
"v": 1
196+
}
197+
{
198+
"e": XXXX,
199+
"m": "serverless.integration_test.execution",
200+
"t": [
201+
"tagkey:tagvalue",
202+
"eventsource:undefined",
203+
"dd_lambda_layer:datadog-nodev16.XX.X"
204+
],
205+
"v": 1
206+
}
123207
END Duration: XXXX ms Memory Used: XXXX MB
124208
START
125209
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed SNS request
@@ -160,6 +244,7 @@ XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed SNS re
160244
}
161245
END Duration: XXXX ms Memory Used: XXXX MB
162246
START
247+
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed SQS request
163248
{
164249
"e": XXXX,
165250
"m": "aws.lambda.enhanced.invocations",
@@ -185,7 +270,6 @@ START
185270
],
186271
"v": 1
187272
}
188-
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed SQS request
189273
{
190274
"e": XXXX,
191275
"m": "serverless.integration_test.records_processed",

‎integration_tests/snapshots/logs/async-metrics_node18.log

Lines changed: 85 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,90 @@ XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed APIGat
3838
}
3939
END Duration: XXXX ms (init: XXXX ms) Memory Used: XXXX MB
4040
START
41+
{
42+
"e": XXXX,
43+
"m": "aws.lambda.enhanced.invocations",
44+
"t": [
45+
"region:eu-west-1",
46+
"account_id:XXXX",
47+
"functionname:integration-tests-js-XXXX-async-metrics_node18",
48+
"resource:integration-tests-js-XXXX-async-metrics_node18",
49+
"memorysize:1024",
50+
"cold_start:false",
51+
"datadog_lambda:vX.X.X",
52+
"runtime:nodejs18.x"
53+
],
54+
"v": 1
55+
}
56+
{
57+
"e": XXXX,
58+
"m": "serverless.integration_test.execution",
59+
"t": [
60+
"tagkey:tagvalue",
61+
"eventsource:undefined",
62+
"dd_lambda_layer:datadog-nodev18.XX.X"
63+
],
64+
"v": 1
65+
}
66+
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
67+
END Duration: XXXX ms Memory Used: XXXX MB
68+
START
69+
{
70+
"e": XXXX,
71+
"m": "aws.lambda.enhanced.invocations",
72+
"t": [
73+
"region:eu-west-1",
74+
"account_id:XXXX",
75+
"functionname:integration-tests-js-XXXX-async-metrics_node18",
76+
"resource:integration-tests-js-XXXX-async-metrics_node18",
77+
"memorysize:1024",
78+
"cold_start:false",
79+
"datadog_lambda:vX.X.X",
80+
"runtime:nodejs18.x"
81+
],
82+
"v": 1
83+
}
84+
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
85+
{
86+
"e": XXXX,
87+
"m": "serverless.integration_test.execution",
88+
"t": [
89+
"tagkey:tagvalue",
90+
"eventsource:undefined",
91+
"dd_lambda_layer:datadog-nodev18.XX.X"
92+
],
93+
"v": 1
94+
}
95+
END Duration: XXXX ms Memory Used: XXXX MB
96+
START
97+
{
98+
"e": XXXX,
99+
"m": "aws.lambda.enhanced.invocations",
100+
"t": [
101+
"region:eu-west-1",
102+
"account_id:XXXX",
103+
"functionname:integration-tests-js-XXXX-async-metrics_node18",
104+
"resource:integration-tests-js-XXXX-async-metrics_node18",
105+
"memorysize:1024",
106+
"cold_start:false",
107+
"datadog_lambda:vX.X.X",
108+
"runtime:nodejs18.x"
109+
],
110+
"v": 1
111+
}
112+
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
113+
{
114+
"e": XXXX,
115+
"m": "serverless.integration_test.execution",
116+
"t": [
117+
"tagkey:tagvalue",
118+
"eventsource:undefined",
119+
"dd_lambda_layer:datadog-nodev18.XX.X"
120+
],
121+
"v": 1
122+
}
123+
END Duration: XXXX ms Memory Used: XXXX MB
124+
START
41125
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed undefined request
42126
{
43127
"e": XXXX,
@@ -160,6 +244,7 @@ XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed SNS re
160244
}
161245
END Duration: XXXX ms Memory Used: XXXX MB
162246
START
247+
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed SQS request
163248
{
164249
"e": XXXX,
165250
"m": "aws.lambda.enhanced.invocations",
@@ -185,7 +270,6 @@ START
185270
],
186271
"v": 1
187272
}
188-
XXXX-XX-XX XX:XX:XX.XXX INFO [dd.trace_id=XXXX dd.span_id=XXXX] Processed SQS request
189273
{
190274
"e": XXXX,
191275
"m": "serverless.integration_test.records_processed",

0 commit comments

Comments
 (0)