MQTT接收各类消息时写入Django模型遇AppRegistryNotReady错误的技术求助

这个报错的核心原因很明确：你在Django的应用还没完全加载完成时，就尝试导入了模型和视图。具体来说，你的__init__.py在Django启动初期就执行了mqtt.client.loop_start()，而mqtt.py顶部直接导入了print.views，视图又导入了Machine模型——这时候Django的AppRegistry还没准备好，自然会抛出错误。

下面是一步步的解决方案：

1. 把MQTT启动逻辑移到AppConfig的ready方法中 #

Django的AppConfig.ready()方法会在所有应用加载完成后被调用，这时候执行MQTT启动逻辑就不会有问题。

首先，修改你的print/apps.py（如果没有就新建这个文件）：

from django.apps import AppConfig

class PrintConfig(AppConfig):
    default_auto_field = 'django.db.models.BigAutoField'
    name = 'print'

    def ready(self):
        # 在这里导入并启动MQTT，避免提前触发模型导入
        import print.mqtt
        print.mqtt.start_mqtt()

然后修改print/__init__.py，替换原来的内容：

default_app_config = 'print.apps.PrintConfig'

2. 调整MQTT模块的导入时机 #

不要在mqtt.py的模块级别导入视图，而是在需要用到的函数内部导入，这样可以延迟导入到Django准备好之后：

修改mqtt.py：

import paho.mqtt.client as mqtt

# 新增一个标记，避免重复启动MQTT循环
mqtt_loop_started = False

def on_connect(client, userdata, rc, properties=None):
    client.subscribe("foo/printers/#")
    print("Connection returned result: " + mqtt.connack_string(rc))

def on_message(client, userdata, msg):
    # 延迟导入handle_msg，直到第一次收到消息时才执行
    from print.views import handle_msg
    handle_msg(msg.topic, msg.payload)

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.username_pw_set(username="foo", password="bar")
client.connect("mqtt.foo.de", 1883, 60)

def start_mqtt():
    global mqtt_loop_started
    if not mqtt_loop_started:
        client.loop_start()
        mqtt_loop_started = True
        print("MQTT loop started successfully")

3. 修正视图中的模型导入路径 #

你原来的from models import Machine可能存在路径问题，需要明确从当前应用导入模型：

修改print/views.py：

# 确保导入路径正确，根据你的应用结构调整
from .models import Machine

def handle_msg(topic, message):
    printer = topic.split("/")[2]
    # 建议增加异常处理，避免找不到Machine时崩溃
    try:
        machine = Machine.objects.get(Name=printer)
        print(machine)
    except Machine.DoesNotExist:
        print(f"警告：未找到名为{printer}的Machine记录")

为什么这样能解决问题？ #

• AppConfig.ready()是Django官方推荐的、在应用完全加载后执行初始化逻辑的地方，确保所有模型和应用配置都已就绪。
• 延迟导入（在函数内部导入视图和模型）避免了在模块加载阶段就触发Django的模型导入逻辑，这时候AppRegistry还没完成初始化。
• 增加mqtt_loop_started标记是为了避免Django在某些场景下（比如runserver时）重复调用ready()方法，导致多次启动MQTT循环。

内容的提问来源于stack exchange，提问作者Felix Dango