-
Notifications
You must be signed in to change notification settings - Fork 1
Description
Wo An Zhao Yan Shi Dai Ma Da Jian Liao Xiang Guan De Cheng Xu ,Zai Dan Liao Shi streamMo Shi Neng Gou Zheng Chang Jie Shou He Fa Song Xiao Xi ,Dan Shi Qun Liao Shi @Ji Qi Ren ,Bing Bu Hui Diao Yong Hui Diao Han Shu ,Quan Liang Xiang Guan Dai Ma Ru Xia
Ding Yi Shi Jian Chu Li Qi
class MyEventHandler(dingtalk_stream.EventHandler):
async def process(self, event: dingtalk_stream.EventMessage):
print(event.headers.event_type, event.headers.event_id, event.headers.event_born_time, event.data)
return AckMessage.STATUS_OK, 'OK'
class MyCallbackHandler(dingtalk_stream.ChatbotHandler):
def init(self):
super(dingtalk_stream.ChatbotHandler, self).init()
async def process(self, callback: dingtalk_stream.CallbackMessage):
print(callback.headers.topic, callback.data)
incoming_message = dingtalk_stream.ChatbotMessage.from_dict(callback.data)
# Wen Ben Xiao Xi Hui Fu
# text = incoming_message.text.content.strip()
# self.reply_text(text, incoming_message)
# MarkdownXiao Xi Hui Fu
text = 'echo received message:\n'
text += '\n'.join(['> 1. %s'%i for i in incoming_message.text.content.strip().split('\n')])
self.reply_markdown('dingtalk-tutorial-python', text, incoming_message)
return AckMessage.STATUS_OK, 'OK'
Qi Dong Ding Ding StreamKe Hu Duan
def start_dingtalk_client():
credential = dingtalk_stream.Credential(APP_KEY, APP_SECRET)
client = dingtalk_stream.DingTalkStreamClient(credential)
#Shi Jian
client.register_all_event_handler(MyEventHandler())
#Xiao Xi Jie Shou
client.register_callback_handler(dingtalk_stream.ChatbotMess age.TOPIC, MyCallbackHandler())
client.start_forever()