oapi-sdk-python
oapi-sdk-python copied to clipboard
update flask sample
使用python内置的queue以及threading给出一个异步处理消息的示例,避免处理超时问题
- 创建一个线程,在worker中调用
handler.do(request)处理业务逻辑 - flask的webhook接口接收事件后,调用
parse_req()解析事件内容,并放入队列,立即返回,避免出现处理业务逻辑超时的问题。
如果使用其他队列,例如rabbitmq之类的。
需要将parse_req()的内容做一下序列化(例如pickle.dumps)再放入队列。
处理的时候,再反序列化(对应的pickle.loads)