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

属性¶

`MessageFilteringType`
`log`

函数¶

`process_response`(response[, message_filtering, ...])	处理 SQS 的响应。
`filter_messages`(messages, message_filtering, ...)
`filter_messages_literal`(messages, ...)
`filter_messages_jsonpath`(messages, ...)

模块内容¶

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]¶

处理 SQS 的响应。

参数:: response (Any) – SQS 的响应
返回:: 处理后的响应
返回类型:: 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]¶