airflow.providers.amazon.aws.utils.sqs¶

Attributes¶

`MessageFilteringType`
`log`

Functions¶

`process_response`(response[, message_filtering, ...])	Process the response from SQS.
`filter_messages`(messages, message_filtering, ...)
`filter_messages_literal`(messages, ...)
`filter_messages_jsonpath`(messages, ...)

Module Contents¶

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

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, parse)[source]¶