airflow.providers.slack.transfers.sql_to_slack¶
模組內容¶
類別¶
在給定的 SQL 連線中執行 SQL 語句，並將結果作為檔案傳送到 Slack API。 |
- class airflow.providers.slack.transfers.sql_to_slack.SqlToSlackApiFileOperator(*, sql, sql_conn_id, sql_hook_params=None, parameters=None, slack_conn_id=SlackHook.default_conn_name, slack_filename, slack_channels=None, slack_initial_comment=None, slack_title=None, slack_base_url=None, slack_method_version='v2', df_kwargs=None, action_on_empty_df='send', **kwargs)[原始碼]¶
基底類別:
airflow.providers.slack.transfers.base_sql_to_slack.BaseSqlToSlackOperator在給定的 SQL 連線中執行 SQL 語句，並將結果作為檔案傳送到 Slack API。
另請參閱
有關如何使用此運算子的更多資訊，請查看指南： SqlToSlackApiFileOperator
- 參數
sql (str) – 要執行的 SQL 查詢
sql_conn_id (str) – 參考特定的 DB-API 連線。
slack_conn_id (str) – Slack API 連線。
slack_filename (str) – Slack 中顯示的檔案名稱。應包含參考
SUPPORTED_FILE_FORMATS的支援副檔名。也可以在副檔名中設定壓縮：filename.csv.gzip,filename.json.zip等。sql_hook_params (dict | None) – 要傳遞到基礎 Hook 的額外配置參數。應符合所需的 Hook 建構子參數。
parameters (list | tuple | collections.abc.Mapping[str, Any] | None) – 要傳遞給 SQL 查詢的參數。
slack_channels (str | collections.abc.Sequence[str] | None) – 將在其中分享檔案的頻道名稱或 ID 的逗號分隔列表。如果省略此參數，則檔案將傳送到工作區。
slack_initial_comment (str | None) – 在指定的
slack_channels中介紹檔案的訊息文字。slack_title (str | None) – 檔案標題。
slack_base_url (str | None) – 代表 Slack API 基礎 URL 的字串。選填
slack_method_version (typing_extensions.Literal[v1, v2]) – 要使用的 Slack SDK Client 方法版本，可以是 "v1" 或 "v2"。
df_kwargs (dict | None) – 轉發到
pandas.DataFrame.to_{format}()方法的關鍵字引數。action_on_empty_df (typing_extensions.Literal[send, skip, error]) –
指定如何處理空的 SQL 輸出 df。可能的值
send: (預設) 傳送包含空檔案的 slack。skip: 跳過傳送 slack 訊息。任務狀態設定為 “skipped”。error: 引發錯誤以使任務失敗。任務狀態設定為 “failed”。
- template_fields: collections.abc.Sequence[str] = ('sql', 'slack_channels', 'slack_filename', 'slack_initial_comment', 'slack_title')[原始碼]¶
- template_ext: collections.abc.Sequence[str] = ('.sql', '.jinja', '.j2')[原始碼]¶
- SUPPORTED_FILE_FORMATS: collections.abc.Sequence[str] = ('csv', 'json', 'html')[原始碼]¶