Serverless OTEL Example

index.ts

// index.ts
import { initializeTelemetry } from './initialize';
import { APIGatewayProxyEvent, APIGatewayProxyResult } from 'aws-lambda';
import { SQSClient, SendMessageCommand, SendMessageCommandInput } from '@aws-sdk/client-sqs';

const sqsClient = new SQSClient({});

const publishMessage = async () => {
    const input: SendMessageCommandInput = {
        QueueUrl: process.env.QUEUE_URL,
        MessageBody: 'test-message'
    };
    const command = new SendMessageCommand(input);
    await sqsClient.send(command)
}

export const handler = async (event: APIGatewayProxyEvent) : Promise<APIGatewayProxyResult> => {
    //const sdk = initializeTelemetry();
    let resp: APIGatewayProxyResult
    try {
        await publishMessage();
        resp = {
            statusCode: 200
        }
    } catch (err) {
        resp = {
            statusCode: 500
        }
    }
    //await sdk.shutdown();
    return resp;
}

initialize.ts

// initialize.ts
import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node';
import { PeriodicExportingMetricReader } from '@opentelemetry/sdk-metrics';
import { NodeSDK } from '@opentelemetry/sdk-node';
import { OTLPMetricExporter } from '@opentelemetry/exporter-metrics-otlp-proto';
import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-proto';

export const initializeTelemetry = () => {
  const sdk = new NodeSDK({
    autoDetectResources: true,
    instrumentations: [getNodeAutoInstrumentations({
      '@opentelemetry/instrumentation-aws-lambda': {
        disableAwsContextPropagation: true
      },
    })],
    traceExporter: new OTLPTraceExporter(),
    metricReader: new PeriodicExportingMetricReader({
      exporter: new OTLPMetricExporter()
    })
  });
  sdk.start();
  return sdk;
}

setup.ts

//setup.ts
import { initializeTelemetry } from './initialize'

initializeTelemetry()