airflow.providers.amazon.aws.hooks.sns¶

此模組包含 AWS SNS hook。

類¶

與 Amazon Simple Notification Service 互動。

模組內容¶

class airflow.providers.amazon.aws.hooks.sns.SnsHook(*args, **kwargs)[source]¶

基類: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

與 Amazon Simple Notification Service 互動。

提供對 boto3.client("sns") 的輕量級封裝。

可以指定額外引數（例如 aws_conn_id），這些引數會傳遞到底層的 AwsBaseHook。

另請參閱

airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

publish_to_target(target_arn, message, subject=None, message_attributes=None)[source]¶

將訊息釋出到 SNS 主題或端點。

另請參閱

SNS.Client.publish()

引數:

target_arn (str) – TopicArn 或 EndpointArn 之一
message (str) – 要傳送的預設訊息
subject (str | None) – 訊息主題
message_attributes (dict | None) –
用於訊息過濾的附加屬性。這應該是一個扁平字典；傳送的資料型別取決於值的型別
- bytes = Binary
- str = String
- int, float = Number
- iterable = String.Array

此條目是否有幫助？