观测云告警对接华为 WeLink 最佳实践

华为云 WeLink 是华为推出的全场景数字化协同办公平台，旨在帮助企业实现高效、安全的在线协作。观测云则是专为 IT 工程师打造的全链路可观测性平台，具备完善的异常监测体系，能够对基础设施、应用程序及日志等各类数据进行实时监控，并在发现异常时自动触发告警。本文主要介绍如何将观测云的告警信息推送至 WeLink 的实现方式。

前置条件

- [观测云 SaaS](https://auth.guance.com/login/pwd)

- [安装 Func](https://func.guance.com/doc/maintenance-guide-requirement/)

配置 Webhook 机器人

点击群右上角的齿轮图表，弹出讨论组，在“讨论组管理”下面点击“群助手”。

点击“添加群助手”，再点击“创建”。

点击“去创建”。

输入名称后，点击“添加”。

保存 Webhook 后，点击“保存。

配置 Func

编写脚本

import requests

import json

import time

import uuid

@DFF.API('自定义发送 weLink')

def send_welink(**kwargs):

token = _DFF_HTTP_REQUEST.get('query').get('token')

title = kwargs.get('df_title','事件告警')

messageJson = [kwargs.get('df_message','告警')]

status = kwargs.get('df_status','info')

msgStr = messageJson[0]

url = kwargs.get('df_event_link')

jumpHtml = url

webhook_url = "https://open.welink.huaweicloud.com/api/werobot/v1/webhook/send"

params = {

"token": token,

"channel": "standard"

}

# 请求头（Headers）

headers = {

"Content-Type": "application/json", # 必须指定 JSON 格式

"Accept": "application/json"

}

# 请求体（Body），发送的消息内容

payload = {

"messageType": "text",

"content": {

"text": msgStr + "\n\n" + jumpHtml # 消息内容

},

"timeStamp": int(time.time() * 1000), # 毫秒时间戳

"uuid": uuid.uuid4().hex # 32 位十六进制字符串

}

# 发送 POST 请求

response = requests.post(

webhook_url,

params=params, # URL 参数（token 和 channel）

headers=headers,

data=json.dumps(payload) # 将字典转为 JSON 字符串

)

# 打印响应

print("Status Code:", response.status_code)

print("Response:", response.json())