SqlToSlackApiFileOperator¶

使用 SqlToSlackApiFileOperator 通过 Slack API 将查询结果作为文件发布到 Slack 频道。

使用操作符¶

注意

操作符支持两种上传文件的方法，由 slack_method_version 控制，默认情况下它使用 Slack SDK 方法 upload_files_v2，可以通过将 v1 设置为 slack_method_version 来使用旧版 upload_files 方法，但由于它可能会影响性能、导致随机 API 错误，并且将于 2025 年 3 月 11 日终止，此外，从 2024 年 5 月 8 日开始，新创建的应用将无法使用此 API 方法，因此不建议使用此方法。

如果您之前使用 v1，则应检查您的应用程序是否具有适当的范围

files:write - 用于写入文件。
files:read - 用于读取文件（如果您使用 Slack SDK >= 3.23.0 则不需要）。
channels:read - 获取公共频道的列表，用于将频道名称转换为频道 ID。
groups:read - 获取私有频道的列表，用于将频道名称转换为频道 ID
mpim:read - API 方法 conversations.list 的附加权限
im:read - API 方法 conversations.list 的附加权限

另请参见

此操作符将在提供的 SQL 连接中执行自定义查询，并将文件发布到 Slack 频道。

SqlToSlackApiFileOperator 的示例用法如下

tests/system/providers/slack/example_sql_to_slack.py[源代码]

SqlToSlackApiFileOperator(
    task_id="sql_to_slack_api_file",
    sql_conn_id=SQL_CONN_ID,
    sql="SELECT 6 as multiplier, 9 as multiplicand, 42 as answer",
    slack_channels="C123456",
    slack_conn_id="slack_api_default",
    slack_filename="awesome.json.gz",
    slack_initial_comment="Awesome compressed multiline JSON.",
    df_kwargs={"orient": "records", "lines": True},
)