airflow.providers.google.cloud.triggers.pubsub¶
此模块包含 Google Cloud Pub/Sub 触发器。
模块内容¶
类¶
使用所需的参数初始化 Pub/Sub 拉取触发器。 |
- class airflow.providers.google.cloud.triggers.pubsub.PubsubPullTrigger(project_id, subscription, max_messages, ack_messages, gcp_conn_id, poke_interval=10.0, impersonation_chain=None)[源代码]¶
基类：
airflow.triggers.base.BaseTrigger使用所需的参数初始化 Pub/Sub 拉取触发器。
- 参数
project_id (str) – 订阅的 Google Cloud 项目 ID（已模板化）
subscription (str) – Pub/Sub 订阅名称。不要包含完整的订阅路径。
max_messages (int) – 每次 Pub/Sub 拉取请求要检索的最大消息数
ack_messages (bool) – 如果为 True，则每条消息将立即确认，而不是由任何下游任务确认
gcp_conn_id (str) – 引用 google cloud 连接 ID
poke_interval (float) – 检查状态的轮询间隔（以秒为单位）
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选的服务帐户，用于使用短期凭据模拟，或用于获取列表中最后一个帐户的 access_token 的链接帐户列表，该帐户将在请求中模拟。如果设置为字符串，则该帐户必须向原始帐户授予服务帐户令牌创建者 IAM 角色。如果设置为序列，则列表中的身份必须向直接前面的身份授予服务帐户令牌创建者 IAM 角色，列表中的第一个帐户将此角色授予原始帐户（已模板化）。