Airflow SlackWebhookOperator消息格式求助：链接可点击与特殊字符处理

一、处理自动添加的<>符号 #

第三个链接被自动包裹< >，大概率是链接本身或数据流转环节中触发了自动转义逻辑（比如包含特殊字符、空格）。可以通过预处理清除多余符号：

# 清除链接前后的<>和空格
cleaned_links = [link.strip('<> ') for link in raw_links]

二、确保所有链接可点击并按每行展示 #

Slack支持两种可点击链接格式，任选其一即可：

1. 纯URL格式：直接输出处理后的纯URL，每行一个，Slack会自动识别为可点击链接：

   # 构造每行一个链接的消息文本
   message_text = "\n".join(cleaned_links)
   

   最终发送到Slack的效果就是：

   https://url1.com/ext
   https://url2.com/ext
   https://url3.com/ext
   

2. 显式Markdown链接格式：如果需要自定义链接显示文本，用[显示文本](URL)格式：

   message_text = "\n".join([f"[{link}]({link})" for link in cleaned_links])
   

三、处理UTF-8与特殊字符 #

• 确保消息文本为UTF-8编码：Python字符串默认支持UTF-8，若遇特殊字符（如中文、*、_等），可通过str.encode('utf-8').decode('utf-8')强制编码转换。
• URL中的特殊字符需确保已做URL编码（如空格转%20），避免Slack解析异常。

完整代码示例 #

from airflow.providers.slack.operators.slack_webhook import SlackWebhookOperator

# 原始链接列表
raw_links = ["https://url1.com/ext", "https://url2.com/ext", "< https://url3.com/ext >"]

# 预处理链接
cleaned_links = [link.strip('<> ') for link in raw_links]

# 构造消息文本
message_text = "\n".join(cleaned_links)

# 定义Slack任务
send_slack_links = SlackWebhookOperator(
    task_id="send_slack_formatted_links",
    slack_webhook_conn_id="your_slack_webhook_conn",
    message=message_text,
    username="Airflow通知机器人"
)

内容的提问来源于stack exchange，提问作者Mavarocks