运行另一个多处理。

Question

问题

我需要在不同端口上运行多个UDP服务器，这些端口将数据与Django Core交换，因此我定义了一个Django命令，该命令调用方法（start_udp_core），该命令在单独的过程中运行每个UDP服务器。我使用socketserver.udpserver，并使用称为serverdata的Django模型存储了套接字的所需数据。 Django版本为4.0.5，

因此我想出了此代码：

from core.models import ServerData
from .data_receiver import UPDRequestHandler

def create_and_start_server(host, server_data):
    with UDPServer((host, server_data["port"]), UPDRequestHandler) as server:
        try:
            logger.info(f"server is listening ... {server.server_address}")
            server.serve_forever()
        except KeyboardInterrupt:
            print("... going off ...")
        except Exception as e:
            logger.error(str(e))


def start_udp_core():
    all_servers = ServerData.objects.values()
    logger.info(f"servers data ... {all_servers}")
    db.connections.close_all()
    default_host = "0.0.0.0"
    for server_data in all_servers:
        multiprocessing.Process(target=create_and_start_server, args=(default_host, card_data)).start()

使用manage.py，appRegistrynotready：apps尚未加载后，正在升级 appRegistrynotready：

INFO - start_udp_core - servers data ... - <QuerySet [{'id': 1, 'type_id': 1, 'ip': '192.168.0.50', 'port': 5000}, {'id': 2, 'type_id': 1, 'ip': '192.168.0.51', 'port': 5001}]>
Traceback (most recent call last):
  File "<string>", line 1, in <module>
Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "c:\...\python\python39\lib\multiprocessing\spawn.py", line 116, in spawn_main
  File "c:\...\python\python39\lib\multiprocessing\spawn.py", line 116, in spawn_main
    exitcode = _main(fd, parent_sentinel)
  File "c:\...\python\python39\lib\multiprocessing\spawn.py", line 126, in _main
    exitcode = _main(fd, parent_sentinel)
  File "c:\...\python\python39\lib\multiprocessing\spawn.py", line 126, in _main
    self = reduction.pickle.load(from_parent)
  File "D:\...\project\radio\start_udp_core.py", line 6, in <module>
    self = reduction.pickle.load(from_parent)
  File "D:\...\project\radio\start_udp_core.py", line 6, in <module>
    from core.models import ServerData
  File "D:\...\project\core\models.py", line 4, in <module>
    from core.models import ServerData
  File "D:\...\project\core\models.py", line 4, in <module>
    class ServerType(models.Model):
  File "D:\...\project\venv\lib\site-packages\django\db\models\base.py", line 128, in __new__
    class ServerType(models.Model):
  File "D:\...\project\venv\lib\site-packages\django\db\models\base.py", line 128, in __new__
    app_config = apps.get_containing_app_config(module)
  File "D:\...\project\venv\lib\site-packages\django\apps\registry.py", line 260, in get_containing_app_config
    app_config = apps.get_containing_app_config(module)
  File "D:\...\project\venv\lib\site-packages\django\apps\registry.py", line 260, in get_containing_app_config
    self.check_apps_ready()
  File "D:\...\project\venv\lib\site-packages\django\apps\registry.py", line 138, in check_apps_ready
    self.check_apps_ready()
  File "D:\...\project\venv\lib\site-packages\django\apps\registry.py", line 138, in check_apps_ready
    raise AppRegistryNotReady("Apps aren't loaded yet.")
django.core.exceptions.AppRegistryNotReady: Apps aren't loaded yet.
    raise AppRegistryNotReady("Apps aren't loaded yet.")
django.core.exceptions.AppRegistryNotReady: Apps aren't loaded yet.

Process finished with exit code 0

现在，有重复的行，因为DB中有两个serverdata s，如您所见，服务器数据列表已成功获取和记录。关于“为什么会发生这种情况？”有什么想法。问题？ （我在将其绑定到django之前测试了多处理代码，没有问题。）

修复

我将create_and_start_server函数移动到另一个文件，然后再次运行命令，然后才起作用！ 请参阅下面的日志：

INFO - start_udp_core - servers data ... - <QuerySet [{'id': 1, 'type_id': 1, 'ip': '192.168.0.50', 'port': 5000}, {'id': 2, 'type_id': 1, 'ip': '192.168.0.51', 'port': 5001}]>
INFO - create_and_start_server - server is listening ... ('0.0.0.0', 5000)
INFO - create_and_start_server - server is listening ... ('0.0.0.0', 5001)

所以现在我想知道这是怎么可能的？我将感谢任何有用的解释。

即使在修复程序后，更新

此问题的MACOS仍具有相同的追溯。