@Richard14 我把线程改用 aiohttp 后，也是出现请求丢失的现象，这是怎么回事？和服务端处理请求速度是不是有关？

@future0906 不用线程的话,函数 b 请求过多，会比较慢

@corvofeng 有可能，不过运行的程序都是在主机上，只有 es,mongodb,redis 用的 docker,我把 es 切换到主机上

@zhoudaiyu 看过了，并没有什么解决方法，只是说 Lock already taken - skipping run 是一个特性。。。。

@deplivesb 这个计算方式有什么依据吗？

tmjzzrsyy

@long2ice 定时查询用的

@vicalloy 好的，感谢感谢

因为 columns 进行了特殊处理,得再定义一个普通的 columns,然后自定义导出数据就行了

感谢各位的解答

好的，谢谢解答

#!/usr/bin/env python3

from redis import Redis
from multiprocessing import Pool
from rq import Queue, Worker, Connection

redis_conn = Redis(host = '127.0.0.1', password = '', port = 6379)

def worker(listen):
with Connection(redis_conn):
worker = Worker(map(Queue, listen))
worker.work()

if __name__ == "__main__":
listen = ['high', 'default', 'low']
worker(listen)

scan_data = {
'target': target,
}
scan = Scan(mysqldb)
q.enqueue(scan.async_exe, scan_data)

def async_exe(self, kwargs):
thread = threading.Thread(target = self.run, args=(kwargs,), daemon = True)
thread.start()

def run(self, kwargs):
for i in range(1000):
print(i)

@wzwwzw OK

@Latin 好的，谢谢，我再试试

@Latin flask-socketio 这个库不支持 http 的请求，与其它的请求不能共存,这就有点难受了😣

@hxy100 是的，我是在机器上用安装的 postfix,然后用其他的域名达到了效果

@tonyaiken 配置这个东西本身不麻烦，而是这种方式麻烦

@Hilalum 单纯的 4 行代码当然简单，但这种方式个人觉着不好用