oapi-sdk-python icon indicating copy to clipboard operation
oapi-sdk-python copied to clipboard

update flask sample

Open lloydzhou opened this issue 1 year ago • 2 comments

使用python内置的queue以及threading给出一个异步处理消息的示例,避免处理超时问题

  1. 创建一个线程,在worker中调用handler.do(request)处理业务逻辑
  2. flask的webhook接口接收事件后,调用parse_req()解析事件内容,并放入队列,立即返回,避免出现处理业务逻辑超时的问题。

lloydzhou avatar Mar 29 '24 06:03 lloydzhou

CLA assistant check
All committers have signed the CLA.

CLAassistant avatar Mar 29 '24 06:03 CLAassistant

如果使用其他队列,例如rabbitmq之类的。

需要将parse_req()的内容做一下序列化(例如pickle.dumps)再放入队列。 处理的时候,再反序列化(对应的pickle.loads)

lloydzhou avatar Mar 29 '24 06:03 lloydzhou