`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`
`MessageFilteringType`

airflow.providers.amazon.aws.utils.sqs.log[source]¶

airflow.providers.amazon.aws.utils.sqs.MessageFilteringType[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, parse)[source]¶

Was this entry helpful?