最终发现回退到老版本：2020.3.4 版本 就好很多 : )

券券 APP

@kkjj 你的路由怎么写的

看你代码，加了什么装饰器

主要是 ip 类型和 ipa 类型之间有父子关系，这样写 ipa 表中的数据会找不到它的父

更正：
我的问题是，如何通过 logstash 将 Mysql 数据的两张表直接同步 ES 中的索引（索引中有两个 types，为父子关系），或者有没有其他的方法达到此目的

楼主，求联系方式

楼主，请问你有数据库同步到 ES 的操作么，使用的是啥插件？ logstash-input-jdbc 吗?

楼主也在做 ES 啊，在下小白

加个内存条就行，我的 pycharm 日常 600MB 内存

@NoAnyLove 感谢。没错，我的线程中还存在从文件中读取记录的 I/O 操作，基本代码如下：
```
...
with open(records1.txt', 'rb') as rf:
record = rf.readline()
while record:
records.append(record)
if len(records) == 500:
currenct_insert_sql = function1(records) # records 列表存五百条 record 后做一次数据库 I/O
if self.mysql_lock.acquire():
cursor.execute(current_insert_sql)
connection.commit()
self.mysql_lock.release()
records = []
record = rf.readline()
...
```
现在准备参考你的建议，尝试协程和更换 mysql 库，等测试出结果后会反馈出来。

没错，我的线程中还存在从文件中读取记录的 I/O 操作，基本代码如下：
```
with open('recors.txt', 'rb') as rf:

抱歉没有说明清楚，我使用的是 mysql 数据库，使用的 python 库是 pymysq。我使这里设置锁的原因是：我每一个线程都有一个连接数据库的链接（或者说是保持连接的句柄），如果我不加锁地去跑 50 个线程，会出现(Lock wait timeout exceeded; try restarting transaction)的报错，所以我在这里设置锁去保证同时只有一个线程去对数据库操作：
```
if self.mysql_lock.acquire():
cursor.execute(current_insert_sql)
connection.commit()
self.mysql_lock.release()
```
不知我这种设计是否合理？

windows? 难道说 linux 的 python2 支持？

问题解决，celery -A tasks worker --loglevel=info --pool=solo （添加参数 --pool=solo ）
https://cn.v2ex.com/t/177589

楼主厉害了，需要小弟打杂么

感谢各位大神给的思路

大佬 你是怎么爬下来的？百度云盘有 api ？