AWS Lambda

Use this node to invoke an AWS Lambda function synchronously and use its response as the outgoing message — for example, running complex ML inference on device data, enriching telemetry by calling a Lambda that queries an external database, or delegating business logic to serverless functions.

• Function name — required. Lambda function name or ARN. Supports templatization.
• Qualifier — function version or alias. Default: $LATEST.
• AWS Access Key ID / Secret Access Key / Region — required. IAM credentials with Lambda invoke permissions.
• Connection timeout (s) — timeout for establishing the connection. Default: 10.
• Request timeout (s) — timeout for the Lambda response. Default: 5.
• Tell failure if function throws exception — when enabled, routes via Failure if the Lambda response contains a non-null FunctionError field.

The AWS request ID is added to message metadata as requestId.

1. Invoke the Lambda function synchronously (RequestResponse) with the incoming message data as the payload.
2. On success: replace the outgoing message data with the Lambda response body; add requestId to metadata; route via Success.
3. If tellFailureIfFuncThrowsExc is enabled and the response contains FunctionError: route via Failure.
4. On connection/request timeout, invalid credentials, or function not found: route via Failure.

Originator: DEVICE | Data: { "temperature": 25.5, "deviceId": "dev-001" }.

{
  "functionName": "arn:aws:lambda:us-east-1:123456789:function:EnrichTelemetry",
  "qualifier": "$LATEST",
  "accessKey": "AKIAIOSFODNN7EXAMPLE",
  "secretKey": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY",
  "region": "us-east-1",
  "connectionTimeout": 10,
  "requestTimeout": 5,
  "tellFailureIfFuncThrowsExc": true
}

Result: Lambda response replaces message data; requestId added to metadata. Routes via Success.

{
  "$schema": "https://json-schema.org/draft/2020-12/schema",
  "title": "TbAwsLambdaNodeConfiguration",
  "type": "object",
  "required": ["functionName", "accessKey", "secretKey", "region"],
  "additionalProperties": false,
  "properties": {
    "functionName": { "type": "string" },
    "qualifier": { "type": "string" },
    "accessKey": { "type": "string" },
    "secretKey": { "type": "string" },
    "region": { "type": "string" },
    "connectionTimeout": { "type": "integer" },
    "requestTimeout": { "type": "integer" },
    "tellFailureIfFuncThrowsExc": { "type": "boolean" }
  }
}