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

模块内容¶

函数¶

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

属性¶

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

处理来自 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]¶

此条目是否对您有帮助？