Gitlab 发送企微机器人消息 - 图1

Gitlab 配置

image.png :::info => 高级用法 开启鉴权 :::

  1. - 在 Gitlab 配置好之后 Secret token
  2. - 在服务端接收推送时验证

实现中转站服务

:::warning 基本需求说明：

  • 可以 接受 gitlab 的 event 推送
  • 可以 发送 消息到微信服务器
  • 稳定 :::

我采用的方式， 腾讯云函数；薅羊毛的方式

  1. import os
  2. import json
  3. from flask import Flask, jsonify, render_template, request, url_for, send_from_directory
  4. from werkzeug.utils import secure_filename
  5. import requests
  7. IS_SERVERLESS = bool(os.environ.get('SERVERLESS'))
  8. print(IS_SERVERLESS)
  10. app = Flask(__name__)
  12. # send_msg_wecom
  13. def msg_send_wecom(md_content):
  14.     """msg_send_wecom
  15.     {
  16.         "msgtype": "markdown",
  17.         "markdown": {
  18.             "content": "实时新增用户反馈<font color=\"warning\">132例</font>，请相关同事注意。\n
  19.              >类型:<font color=\"comment\">用户反馈</font>
  20.              >普通用户反馈:<font color=\"comment\">117例</font>
  21.              >VIP用户反馈:<font color=\"comment\">15例</font>"
  22.         }
  23.     }
  24.     """
  26.     url = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key="
  28.     webhooks = ["xxxxxxxxxxxxxxxxxxxxxxxxxxx"] # 多个 webhook 需要推送时
  29.     headers = {'Content-Type': 'application/json'}
  31.     message = {
  32.         "msgtype": "markdown",
  33.         "markdown": {
  34.             "content": md_content
  35.             }
  36.         }
  38.     for webhook in webhooks:
  39.         try:
  40.             requests.post(url=url+webhook, headers=headers, json=message)
  41.         except Exception as e: 
  42.             print(e)
  45. @app.route("/from_gitlab_webhook", methods=['POST'])
  46. def say_hello():
  47.     data = request.get_json()
  48.     event_type = data['object_kind']
  50.     resp = {
  51.         'event': event_type,
  52.         }
  54.     md_content = ""
  56.     if event_type == 'push':
  57.         resp['commit_msg'] = data['commits'][0]['message'].replace("\n", "")
  58.         resp['author'] = data['user_username']
  59.         resp['project_name'] = data['project']['name']
  60.         resp['project_url'] = data['project']['web_url']
  62.         # fit md_content
  63.         md_content += "## 文档站 <font color=\"info\">{}</font> 通知: \n\n".format(resp['event'])
  64.         md_content += "- 项目: [{}]({}) \n".format(resp['project_name'],resp['project_url'])
  65.         md_content += "- 更新人: *{}* \n".format(resp['author'])
  66.         md_content += "- 提交信息: {} \n".format(resp['commit_msg'])
  68.     elif event_type == 'build':
  69.         resp['author'] = data['user']['username']
  70.         resp['project_name'] = data['repository']['name']
  71.         resp['project_url'] = data['repository']['homepage']
  72.         resp['commit_msg'] = data['commit']['message'].replace("\n", "")
  73.         resp['build_status'] = data['build_status']
  74.         resp['build_duration'] = int(data['build_duration']) + 1
  76.         if resp['build_status'] == 'failed':
  77.             md_content += "## 文档站 {} <font color=\"warning\">{}</font> 通知: \n\n".format(resp['event'], resp['build_status'])
  78.             md_content += "- 项目: [{}]({}) \n".format(resp['project_name'],resp['project_url'])
  79.             md_content += "- 请 **{}** 关注最近提交的内容 \n".format(resp['author'])
  80.             md_content += "- 提交信息: {} \n".format(resp['commit_msg'])
  82.     msg_send_wecom(md_content)
  84.     print("INFO: " + json.dumps(resp))
  85.     return json.dumps(resp)
  87. @app.route("/")
  88. def index():
  89.     return {"code": 200, "msg": "it's ok!"}
  91. # 启动服务，监听 9000 端口，监听地址为 0.0.0.0
  92. app.run(debug=IS_SERVERLESS != True, port=9000, host='0.0.0.0')

创建企微群机器人

成功创建机器人后，会获取到一个 用于推送消息的 webhook Key
image.png :::info => 高级用法 针对推送来源进行 IP 限制 ::: image.png

消息呈现展示

image.png