如何在所有运行的Django实例中执行指定代码？

嘿，针对你遇到的这个痛点——要让所有正在运行的Django worker进程（比如uWSGI管理的那些）执行特定代码，又不想用Celery独立进程、不想搞中间件轮询数据库、也不想重启进程，我有两个非常贴合场景的方案：

方案一：利用uWSGI原生信号广播（最贴合你的场景） #

uWSGI本身就支持向所有worker进程发送自定义信号，我们只要在Django里注册对应的信号处理函数，就能让每个worker收到信号时自动执行目标代码。

步骤1：在Django中注册信号处理器 #

找个项目初始化时会加载的文件（比如wsgi.py或者专门的signals.py），加这段代码：

import uwsgi

def run_target_code(signum):
    # 这里写你要在每个worker里执行的逻辑
    print(f"Worker {uwsgi.worker_id()} 已执行目标代码")
    # 比如更新本地动态配置缓存、执行特定业务操作等

# 注册一个自定义信号（选个不冲突的编号，比如17）
uwsgi.register_signal(17, "", run_target_code)
# 让当前worker监听这个信号
uwsgi.add_signal(17, "")

步骤2：触发所有worker执行 #

当你需要执行代码时，要么用uWSGI命令行发信号：

uwsgi --signal 17 --ini your_uwsgi_config.ini

要么在Django代码里（比如管理命令、后台视图）触发：

import uwsgi
uwsgi.signal(17)  # 广播信号给所有worker

这个方案的好处：

• 代码直接在每个worker进程内跑，和业务上下文完全一致，没有跨进程的麻烦
• 实时触发，不用重启进程，对服务完全无影响
• 完全依托uWSGI的原生能力，没有额外依赖

方案二：用Redis Pub/Sub做跨进程事件触发（兼容性更强） #

如果你担心以后换WSGI服务器（比如从uWSGI换到Gunicorn），可以用轻量的消息队列做全局触发——让所有worker监听同一个Redis频道，收到指令就执行代码。

步骤1：在worker启动时启动监听线程 #

在wsgi.py里加这段：

import threading
import redis
from django.conf import settings

def listen_global_commands():
    r = redis.Redis(host=settings.REDIS_HOST, port=settings.REDIS_PORT)
    pubsub = r.pubsub()
    pubsub.subscribe("django_global_exec")
    
    for msg in pubsub.listen():
        if msg["type"] == "message" and msg["data"].decode() == "run_target":
            # 执行你的目标代码
            print(f"Worker 线程 {threading.get_ident()} 已执行目标代码")

# 启动后台监听线程（设置为守护线程，随worker进程退出）
threading.Thread(target=listen_global_commands, daemon=True).start()

步骤2：触发执行 #

在需要的地方（比如管理命令、后台操作）发消息：

import redis
from django.conf import settings

r = redis.Redis(host=settings.REDIS_HOST, port=settings.REDIS_PORT)
r.publish("django_global_exec", "run_target")

这个方案的优势：

• 不绑定uWSGI，换其他WSGI服务器也能用
• 可以扩展支持更复杂的指令，不止是执行一段固定代码

为什么这两个方案比你之前的思路更优雅？ #

• 避开了Celery的独立进程：代码直接在Django worker内执行，和业务上下文完全对齐，不需要处理跨进程的数据同步问题
• 没有中间件轮询的开销：不管是uWSGI信号还是Redis Pub/Sub都是事件驱动，只有需要执行时才触发，不会一直查数据库浪费资源
• 完全不用重启进程：实时触发，服务可用性不受影响

另外，针对你提到的动态配置项场景，这两个方案都完美适配——比如配置更新时，触发信号或Pub/Sub消息，让所有worker实时刷新本地配置缓存，完全不需要额外的缓存层或者重启操作。

内容的提问来源于stack exchange，提问作者Anton Pererva