airflow.providers.slack.transfers.base_sql_to_slack¶

类¶

BaseSqlToSlackOperator

此操作符实现了用于 SQL 到 Slack 传输操作符的基础 SQL 方法。

模块内容¶

class airflow.providers.slack.transfers.base_sql_to_slack.BaseSqlToSlackOperator(*, sql, sql_conn_id, sql_hook_params=None, parameters=None, slack_proxy=None, slack_timeout=None, slack_retry_handlers=None, **kwargs)[source]¶

基类: airflow.models.BaseOperator

此操作符实现了用于 SQL 到 Slack 传输操作符的基础 SQL 方法。

参数:

sql (str) – 要执行的 SQL 查询
sql_conn_id (str) – 对特定 DB-API 连接的引用。
sql_hook_params (dict | None) – 传递给底层 hook 的额外配置参数。应与所需的 hook 构造函数参数匹配。
parameters (list | tuple | collections.abc.Mapping[str, Any] | None) – 传递给 SQL 查询的参数。
slack_proxy (str | None) – 用于进行 Slack Incoming Webhook / API 调用的代理。可选
slack_timeout (int | None) – 客户端等待连接并接收 Slack 响应的最大秒数。可选
slack_retry_handlers (list[slack_sdk.http_retry.RetryHandler] | None) – 用于自定义重试逻辑的处理程序列表。可选

sql_conn_id[source]¶

sql_hook_params = None[source]¶

sql[source]¶

parameters = None[source]¶

slack_proxy = None[source]¶

slack_timeout = None[source]¶

slack_retry_handlers = None[source]¶