Introduce lambda worker sample #455

lennessyy · 2026-04-24T23:57:10Z

Suggested change

AWS_LAMBDA_EXEC_WRAPPER=/opt/otel-instrument

AWS_LAMBDA_EXEC_WRAPPER=/opt/otel-handler

I think this should be otel-handler. otel-instrument seems to be for Python, not Node.js

-Original file line number
+Diff line change
@@ Expand Up / @@ -111,3 +111,6 @@ package-lock.json @@
     */**/pnpm-lock.yaml
     .idea/
+    **/client.key
+    **/client.pem

-Original file line number
+Diff line change
@@ Expand Up / @@ -17,6 +17,7 @@ const TSCONFIG_EXCLUDE = [ @@
       'production',
       'hello-world-js',
       'food-delivery',
+      'lambda-worker',
       'nestjs-exchange-rates',
       'empty',
       'hello-world',
@@ Expand All / @@ -29,6 +30,7 @@ const GITIGNORE_EXCLUDE = [ @@
       'hello-world-js',
       'protobufs',
       'food-delivery',
+      'lambda-worker',
       'nestjs-exchange-rates',
     ];
     const ESLINTRC_EXCLUDE = [
@@ Expand Down Expand Up / @@ -61,6 +63,7 @@ const POST_CREATE_EXCLUDE = [ @@
       'patching-api',
       'signals-queries',
       'activities-cancellation-heartbeating',
+      'lambda-worker',
       'nestjs-exchange-rates',
       'food-delivery',
       'search-attributes',
@@ Expand Down @@

-Original file line number
+Diff line change
@@ Expand Up / @@ -24,6 +24,7 @@ @@
         "hello-world-js",
         "hello-world-mtls",
         "interceptors-opentelemetry",
+        "lambda-worker",
         "message-passing",
         "monorepo-folders",
         "mutex",
@@ Expand Down Expand Up / @@ -51,4 +52,4 @@ @@
         "worker-specific-task-queues",
         "worker-versioning"
       ]
-    }
+    }

-Original file line number
+Diff line change
@@ -1,2 +1 @@
-    link-workspace-packages = true
-    prefer-workspace-packages = true
+    package-lock=false

-Original file line number
+Diff line change
@@ -0,0 +1,3 @@
+    node_modules
+    lib
+    .eslintrc.js

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Introduce lambda worker sample #455

Uh oh!

Diff view

Diff view

There are no files selected for viewing

lennessyy Apr 24, 2026

Uh oh!

Uh oh!

-Original file line number
+Diff line change
@@ -0,0 +1,48 @@
+    const { builtinModules } = require('module');
+    const ALLOWED_NODE_BUILTINS = new Set(['assert']);
+    module.exports = {
+      root: true,
+      parser: '@typescript-eslint/parser',
+      parserOptions: {
+        project: './tsconfig.json',
+        tsconfigRootDir: __dirname,
+      },
+      plugins: ['@typescript-eslint', 'deprecation'],
+      extends: [
+        'eslint:recommended',
+        'plugin:@typescript-eslint/eslint-recommended',
+        'plugin:@typescript-eslint/recommended',
+        'prettier',
+      ],
+      rules: {
+        // recommended for safety
+        '@typescript-eslint/no-floating-promises': 'error', // forgetting to await Activities and Workflow APIs is bad
+        'deprecation/deprecation': 'warn',
+        // code style preference
+        'object-shorthand': ['error', 'always'],
+        // relaxed rules, for convenience
+        '@typescript-eslint/no-unused-vars': [
+          'warn',
+          {
+            argsIgnorePattern: '^_',
+            varsIgnorePattern: '^_',
+          },
+        ],
+        '@typescript-eslint/no-explicit-any': 'off',
+      },
+      overrides: [
+        {
+          files: ['src/workflows.ts', 'src/workflows-*.ts', 'src/workflows/*.ts'],
+          rules: {
+            'no-restricted-imports': [
+              'error',
+              ...builtinModules.filter((m) => !ALLOWED_NODE_BUILTINS.has(m)).flatMap((m) => [m, `node:${m}`]),
+            ],
+          },
+        },
+      ],
+    };

-Original file line number
+Diff line change
@@ -0,0 +1,5 @@
+    lib
+    node_modules
+    workflow-bundle.js
+    function.zip
+    package/

-Original file line number
+Diff line change
@@ -0,0 +1,54 @@
+    #!/bin/bash
+    set -euo pipefail
+    FUNCTION_NAME="${1:?Usage: deploy-lambda.sh <function-name>}"
+    SCRIPT_DIR="$(cd "$(dirname "$0")" && pwd)"
+    SDK_DIR="$SCRIPT_DIR/../../sdk-node"
+    # Build TypeScript
+    cd "$SCRIPT_DIR"
+    pnpm build
+    # Bundle workflows
+    pnpm build:workflow-bundle
+    # Create packaging directory
+    rm -rf "$SCRIPT_DIR/package"
+    mkdir -p "$SCRIPT_DIR/package"
+    # Copy compiled JS to package root (so index.js is at zip root for the default handler)
+    cp "$SCRIPT_DIR/lib/"*.js "$SCRIPT_DIR/package/"
+    # Copy workflow bundle alongside the handler
+    cp "$SCRIPT_DIR/workflow-bundle.js" "$SCRIPT_DIR/package/"
+    # Install production dependencies.
+    # TODO: Once @temporalio/lambda-worker is published, remove the sed and the
+    # manual copy below — npm install will handle everything.
+    cd "$SCRIPT_DIR/package"
+    sed '/@temporalio\/lambda-worker/d' "$SCRIPT_DIR/package.json" > package.json
+    npm install --omit=dev --ignore-scripts
+    # Strip native binaries for platforms other than Lambda's (linux x86_64)
+    find node_modules/@temporalio/core-bridge/releases -mindepth 1 -maxdepth 1 \
+        ! -name 'x86_64-unknown-linux-gnu' -exec rm -rf {} +
+    # Manually place the local lambda-worker package (not yet published)
+    mkdir -p node_modules/@temporalio/lambda-worker
+    cp "$SDK_DIR/packages/lambda-worker/package.json" node_modules/@temporalio/lambda-worker/
+    cp -r "$SDK_DIR/packages/lambda-worker/lib" node_modules/@temporalio/lambda-worker/
+    # Copy config files and certs
+    cp "$SCRIPT_DIR/temporal.toml" "$SCRIPT_DIR/otel-collector-config.yaml" \
+       "$SCRIPT_DIR/client.pem" "$SCRIPT_DIR/client.key" "$SCRIPT_DIR/package/"
+    # Create zip
+    cd "$SCRIPT_DIR/package"
+    zip -r "$SCRIPT_DIR/function.zip" .
+    # Deploy
+    aws lambda update-function-code --function-name "$FUNCTION_NAME" \
+      --zip-file fileb://"$SCRIPT_DIR/function.zip"
+    # Cleanup
+    rm -rf "$SCRIPT_DIR/package" "$SCRIPT_DIR/function.zip"

-Original file line number
+Diff line change
@@ -0,0 +1,48 @@
+    #!/bin/bash
+    set -euo pipefail
+    # Additional setup steps for OpenTelemetry support.
+    # These are needed if you want metrics, logs, and traces from your Lambda worker.
+    ROLE_NAME="${1:?Usage: extra-setup-steps <role-name> <function-name> <region> <account-id>}"
+    FUNCTION_NAME="${2:?Usage: extra-setup-steps <role-name> <function-name> <region> <account-id>}"
+    REGION="${3:?Usage: extra-setup-steps <role-name> <function-name> <region> <account-id>}"
+    ACCOUNT_ID="${4:?Usage: extra-setup-steps <role-name> <function-name> <region> <account-id>}"
+    # Needed to allow metrics/logs/traces to be published
+    aws iam put-role-policy \
+         --role-name "$ROLE_NAME" \
+         --policy-name ADOT-Telemetry-Permissions \
+         --policy-document "{
+           \"Version\": \"2012-10-17\",
+           \"Statement\": [
+             {
+               \"Effect\": \"Allow\",
+               \"Action\": [
+                 \"logs:CreateLogGroup\",
+                 \"logs:CreateLogStream\",
+                 \"logs:PutLogEvents\"
+               ],
+               \"Resource\": \"arn:aws:logs:${REGION}:${ACCOUNT_ID}:log-group:/aws/lambda/${FUNCTION_NAME}:*\"
+             },
+             {
+               \"Effect\": \"Allow\",
+               \"Action\": [
+                 \"xray:PutTraceSegments\",
+                 \"xray:PutTelemetryRecords\"
+               ],
+               \"Resource\": \"*\"
+             },
+             {
+               \"Effect\": \"Allow\",
+               \"Action\": [
+                 \"cloudwatch:PutMetricData\"
+               ],
+               \"Resource\": \"*\"
+             }
+           ]
+         }"
+    # Needed to make traces show up with type: `"AWS::Lambda::Function"` filter
+    aws lambda update-function-configuration \
+     --function-name "$FUNCTION_NAME" --tracing-config Mode=Active

Introduce lambda worker sample #455

Are you sure you want to change the base?

Uh oh!

Introduce lambda worker sample #455

Uh oh!

Uh oh!

Diff view

Diff view

There are no files selected for viewing

lennessyy Apr 24, 2026

Choose a reason for hiding this comment

Uh oh!

Uh oh!