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