airflow.providers.amazon.aws.executors.aws_lambda.docker.app¶

Attributes¶

`lambda_handler`(event, context)
`run_and_report`(command, task_key)	Execute the provided Airflow command or workload and report the result via SQS.
`get_sqs_client`()	Create an SQS client. Credentials and region are automatically picked up from the environment.
`get_queue_url`()	Get the SQS queue URL from the environment variable.
`fetch_dags_from_s3`(s3_uri)	Fetch Dags from S3 and sync them to the local dags directory.

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.S3_URI[source]¶

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.TASK_KEY_KEY = 'task_key'[source]¶

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.COMMAND_KEY = 'command'[source]¶

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.EXECUTOR_CONFIG_KEY = 'executor_config'[source]¶

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.RETURN_CODE_KEY = 'return_code'[source]¶

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.lambda_handler(event, context)[source]¶

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.run_and_report(command, task_key)[source]¶: Execute the provided Airflow command or workload and report the result via SQS.

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.get_sqs_client()[source]¶: Create an SQS client. Credentials and region are automatically picked up from the environment.

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.get_queue_url()[source]¶

Get the SQS queue URL from the environment variable.

Set either on the Lambda function or in the image used for the lambda invocations.

airflow.providers.amazon.aws.executors.aws_lambda.docker.app.fetch_dags_from_s3(s3_uri)[source]¶: Fetch Dags from S3 and sync them to the local dags directory.