8000 Add DynamoDB Downstream Span Pointers (#600) · DataDog/datadog-lambda-js@99c0b48 · GitHub
[go: up one dir, main page]
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
  • esm_node20_dynamodb-two-key-table.json
  • esm_node22_dynamodb-one-key-table.json
  • esm_node22_dynamodb-remove.json
  • esm_node22_dynamodb-two-key-table.json
  • http-requests_node16_dynamodb-one-key-table.json
  • http-requests_node16_dynamodb-remove.json
  • http-requests_node16_dynamodb-two-key-table.json
  • http-requests_node18_dynamodb-one-key-table.json
  • http-requests_node18_dynamodb-remove.json
  • http-requests_node18_dynamodb-two-key-table.json
  • http-requests_node20_dynamodb-one-key-table.json
  • http-requests_node20_dynamodb-remove.json
  • http-requests_node20_dynamodb-two-key-table.json
  • http-requests_node22_dynamodb-one-key-table.json
  • http-requests_node22_dynamodb-remove.json
  • http-requests_node22_dynamodb-two-key-table.json
  • process-input-traced_node16_dynamodb-one-key-table.json
  • process-input-traced_node16_dynamodb-remove.json
  • process-input-traced_node16_dynamodb-two-key-table.json
  • process-input-traced_node18_dynamodb-one-key-table.json
  • process-input-traced_node18_dynamodb-remove.json
  • process-input-traced_node18_dynamodb-two-key-table.json
  • process-input-traced_node20_dynamodb-one-key-table.json
  • process-input-traced_node20_dynamodb-remove.json
  • process-input-traced_node20_dynamodb-two-key-table.json
  • process-input-traced_node22_dynamodb-one-key-table.json
  • process-input-traced_node22_dynamodb-remove.json
  • process-input-traced_node22_dynamodb-two-key-table.json
  • status-code-500s_node16_dynamodb-one-key-table.json
  • status-code-500s_node16_dynamodb-remove.json
  • status-code-500s_node16_dynamodb-two-key-table.json
  • status-code-500s_node18_dynamodb-one-key-table.json
  • status-code-500s_node18_dynamodb-remove.json
  • status-code-500s_node18_dynamodb-two-key-table.json
  • status-code-500s_node20_dynamodb-one-key-table.json
  • status-code-500s_node20_dynamodb-remove.json
  • status-code-500s_node20_dynamodb-two-key-table.json
  • status-code-500s_node22_dynamodb-one-key-table.json
  • status-code-500s_node22_dynamodb-remove.json
  • status-code-500s_node22_dynamodb-two-key-table.json
  • sync-metrics_node16_dynamodb-one-key-table.json
  • sync-metrics_node16_dynamodb-remove.json
  • sync-metrics_node16_dynamodb-two-key-table.json
  • sync-metrics_node18_dynamodb-one-key-table.json
  • sync-metrics_node18_dynamodb-remove.json
  • sync-metrics_node18_dynamodb-two-key-table.json
  • sync-metrics_node20_dynamodb-one-key-table.json
  • sync-metrics_node20_dynamodb-remove.json
  • sync-metrics_node20_dynamodb-two-key-table.json
  • sync-metrics_node22_dynamodb-one-key-table.json
  • sync-metrics_node22_dynamodb-remove.json
  • sync-metrics_node22_dynamodb-two-key-table.json
  • throw-error-traced_node16_dynamodb-one-key-table.json
  • throw-error-traced_node16_dynamodb-remove.json
  • throw-error-traced_node16_dynamodb-two-key-table.json
  • throw-error-traced_node18_dynamodb-one-key-table.json
  • throw-error-traced_node18_dynamodb-remove.json
  • throw-error-traced_node18 10000 _dynamodb-two-key-table.json
  • throw-error-traced_node20_dynamodb-one-key-table.json
  • throw-error-traced_node20_dynamodb-remove.json
  • throw-error-traced_node20_dynamodb-two-key-table.json
  • throw-error-traced_node22_dynamodb-one-key-table.json
  • throw-error-traced_node22_dynamodb-remove.json
  • throw-error-traced_node22_dynamodb-two-key-table.json
  • src/utils

    • 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)
    0