External Function Connections

Atlas Stream Processing supports embedding calls to AWS Lambda resources within your Atlas Stream Processing pipeline. To learn more, see the Atlas Stream Processing External Functions documentation.

Add an External Function Connection

Create a `config.json` file.

{
 "name": "ExampleExternalFunctionConnection",
 "type": "AWSLambda",
 "aws": {
 "roleArn": "<your-aws-role-arn>"
 }
}

Create the External Function connection.

Run the following Atlas CLI command to create the conection:

atlas streams connections create -i <instance-name> -f </path/to/config.json>

Navigate to your stream processor.

Select the Stream Processing tab in the left sidebar menu in the Atlas UI.

Configure your stream processor connection.

Click the Configure button for your selected stream processor.
Select the Connection Registry tab.
Click the Add Connection button.
Select AWS Lambda from the Connection Type dropdown menu.
Name your new connection.
Select an AWS IAM Role ARN from the dropdown menu. To learn more about creating an AWS IAM Role ARN, see Set Up Unified AWS Access.
Click the Create Connection button to create the connection.

You can add your AWS Lambda resource as a connection through the Atlas UI, the Atlas CLI, or the Atlas API, as shown in the following example. You can update the roleArn placeholder in the example with the arn from your AWS IAM configuration.

curl --user "username:password" --digest \
 --header "Content-Type: application/json" \
 --header "Accept: application/vnd.atlas.2023-02-01+json" \
 --include \
 --data '{"name": "TestAWSLambdaConnection","type": "AWSLambda","aws": {"roleArn": "arn:aws:iam::<aws_account>:role/<role_name>"}}' \
 --request POST "https://cloud.mongodb.com/api/atlas/v2/groups/<group_id>/streams/<tenant_name>/connections"

Back

S3 Connections

Manage Stream Processors