最好能把整个过程都自动化 比如 def do_something(arg1): comp do_something是一个同步调用的函数 如果加上@async，就可以把他变成异步调用的 需要把函数相关的信息和参数相关的信息都传入进去 然后有一个consumer.py来导入相应的函数和执行
