ibuler

报过，不能说一点效果都没把，是基本没啥用

@deplivesb 每天跨城出行？

网上有公布的数据:
2012 年：1635 万
2013 年：1640 万

（ 2013 年 11 月，《关于全面深化改革若干重大问题的决定》提出“启动实施一方是独生子女的夫妇可生育两个孩子的政策”）

2014 年：1687 万
2015 年：1655 万
2016 年：1786 万

（ 2016 年 1 月 1 日我国正式施行“全面二孩政策”，原计划会有第四波婴儿潮，翟振武砖家就预测二胎放开会有 4995 万）

2017 年：1723 万

（ 2016 年 1 月 1 日我国正式施行“全面二孩政策”）
2018 年：1523 万
2019 年：1465 万

2020 年：1200 万

2021 年：1062 万（国统局 2022 年 1 月 18 日公布）

也可以通过信号机制来处理，任务执行前，执行后做同样的动作，这样可能更优雅，其他开发人员，不需要再去处理连接的事情

```
# ops/signal_handlers.py
from django.db import close_old_connections
from celery.signals import task_prerun, task_postrun

@task_prerun.connect()
def on_celery_task_pre_run(task_id='', **kwargs):
# 关闭之前的数据库连接
close_old_connections()


@task_postrun.connect()
def on_celery_task_post_run(**kwargs):
close_old_connections()


# ops/apps.py app 中导入信号处理器

class OpsConfig(AppConfig):
name = 'ops'

def ready(self):
from . import signal_handlers
super().ready()

```

@kidblg 的思路是对的，如果 celery 使用了线程模型，使用完数据库后应该手动关闭连接，这些动作如果在 view 中不用处理，django 自己操作的。

```
# from django.db import close_old_connections 点进去

# Register an event to reset transaction state and close connections past
# their lifetime.
def close_old_connections(**kwargs):
for conn in connections.all():
conn.close_if_unusable_or_obsolete()

signals.request_started.connect(close_old_connections)
signals.request_finished.connect(close_old_connections)

```

所以在 celery 中，用到的查询，都应该手动执行 close_old_connections ，如果是 celery 是 process 模型就不用处理了

支持