1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
#/bin/env python
#-*- coding:utf-8 -*-
import base64
import time, hmac, base64, requests, hashlib,json
def hello_pubsub(event, context):
import base64
print("""This Function was triggered by messageId {} published at {} to {}
""".format(context.event_id, context.timestamp, context.resource["name"]))
if 'data' in event:
name = base64.b64decode(event['data']).decode('utf-8')
print('---version 10----')
print(type(json.loads(name)))
sendMessageFei(sent_content=format_content(json.loads(name)))
else:
name = 'World'
print('Hello {}!'.format(name))
# print(event)
# print(context)
def createFeiSign():
secret = 'YourSecret'
timestamp = int(time.time())
secretBefore = ('%s\n%s' % (timestamp, secret)).encode('utf-8') # 将值转换为byte类型
msg = ""
msgEncode = msg.encode('utf-8')
hsha256 = hmac.new(secretBefore, msgEncode, digestmod=hashlib.sha256).digest() # 用hashlib.sha256进行计算，得出HmacSHA256
sign = base64.b64encode(hsha256).decode() # 先Base64，再decode去掉byte类型，得到sign值
return {"timestamp": timestamp, "sign": sign}
def sendMessageFei(sent_content='大家好，我是飞书群助手机器人'):
#https://open.feishu.cn/document/ukTMukTMukTM/ucTM5YjL3ETO24yNxkjN#4996824a
url = 'https://open.feishu.cn/open-apis/bot/v2/hook/YourFeishuID'
json = {
"timestamp": createFeiSign().get('timestamp'),
"sign": createFeiSign().get('sign'), # 获取函数的值，并get到具体值
"msg_type": "interactive",
"card": {
"config": {
"wide_screen_mode": True,
"enable_forward": True
},
"elements": [{
"tag": "div",
"text": {
"content": sent_content,
"tag": "lark_md"
}
}, {
"actions": [{
"tag": "button",
"text": {
"content": ":汗:控制台看看",
"tag": "lark_md"
},
"url": "https://console.cloud.google.com/logs",
"type": "default",
"value": {}
}],
"tag": "action"
}],
"header": {
"title": {
"content": "GCP实例事件通知",
"tag": "plain_text"
}
}
}
}
r = requests.post(url=url, json=json)
print("send to feishu done")
print(r.json())
def format_content(data):
return ("**实例ID**: %s\n"
"**事件类型**: %s\n"
"**事件事件**: %s\n"
"**事件描述**: %s") %(
data.get('protoPayload',{}).get('resourceName'),
data.get('protoPayload',{}).get('methodName'),
data.get('timestamp'),
data.get('protoPayload',{}).get('status',{}).get('message'))
# if __name__ == '__main__':
# sendMessageFei(sent_content=format_content(mdata))
|