airflow.providers.amazon.aws.utils.sqs

Module Contents

Functions

process_response(response[, message_filtering, ...])

Process the response from SQS.

filter_messages(messages, message_filtering, ...)

filter_messages_literal(messages, ...)

filter_messages_jsonpath(messages, ...)

Attributes

log

airflow.providers.amazon.aws.utils.sqs.log[source]
airflow.providers.amazon.aws.utils.sqs.process_response(response, message_filtering=None, message_filtering_match_values=None, message_filtering_config=None)[source]

Process the response from SQS.

Parameters

response (Any) – The response from SQS

Returns

The processed response

Return type

Any

airflow.providers.amazon.aws.utils.sqs.filter_messages(messages, message_filtering, message_filtering_match_values, message_filtering_config)[source]
airflow.providers.amazon.aws.utils.sqs.filter_messages_literal(messages, message_filtering_match_values)[source]
airflow.providers.amazon.aws.utils.sqs.filter_messages_jsonpath(messages, message_filtering_match_values, message_filtering_config)[source]

Was this entry helpful?