使用Swifter并行处理Django模型写入时报AppRegistryNotReady错误

出现这个错误的核心原因是Swifter启用并行后会创建子进程，这些子进程未加载Django的应用注册表（App Registry），直接调用Django模型操作时就会触发AppRegistryNotReady异常。

解决方案 #

• 在migrate函数内手动初始化Django应用环境，确保每个子进程都能正确加载Django配置：

  def migrate(row):
      # 手动初始化Django环境
      import django
      from django.conf import settings
  
      if not settings.configured:
          # 替换为你的Django项目实际配置
          settings.configure(
              DEBUG=False,
              DATABASES={
                  'default': {
                      'ENGINE': 'django.db.backends.mysql',  # 替换为你的数据库引擎
                      'NAME': 'your_database_name',
                      'USER': 'your_db_user',
                      'PASSWORD': 'your_db_password',
                      'HOST': 'localhost',
                      'PORT': '3306',
                  }
              },
              INSTALLED_APPS=[
                  'your_target_app',  # 包含目标模型的应用名称
              ]
          )
          django.setup()
  
      # 模型导入必须放在django.setup()之后
      from your_target_app.models import YourModel
  
      # 执行数据写入逻辑
      YourModel.objects.create(
          field1=row['field1'],
          field2=row['field2'],
          # 映射其他字段
      )
  

注意事项 #

• 确保settings.configure中的配置与你的Django项目完全一致，特别是INSTALLED_APPS必须包含存放目标模型的应用。
• 模型导入语句务必放在django.setup()之后，避免未初始化就调用模型的错误。

内容的提问来源于stack exchange，提问作者João Felipe Holanda