AwsLambdaInvokeFunctionOperator

Amazon

Invokes an AWS Lambda function. You can invoke a function synchronously (and wait for the response), or asynchronously. To invoke a function asynchronously, set invocation_type to Event. For more details, review the boto3 Lambda invoke docs.

View on GitHub

Last Updated: Mar. 1, 2022

Access Instructions

Install the Amazon provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

function_nameRequiredThe name of the AWS Lambda function, version, or alias.
payloadThe JSON string that you want to provide to your Lambda function as input.
log_typeSet to Tail to include the execution log in the response. Otherwise, set to “None”.
qualifierSpecify a version or alias to invoke a published version of the function.
aws_conn_idThe AWS connection ID to use

Documentation

Invokes an AWS Lambda function. You can invoke a function synchronously (and wait for the response), or asynchronously. To invoke a function asynchronously, set invocation_type to Event. For more details, review the boto3 Lambda invoke docs.

See also

For more information on how to use this operator, take a look at the guide: Invoke an AWS Lambda function

Example DAGs

Was this page helpful?