Django信号实现疑存问题：生产环境文件处理异常求助

我近期部署了一个基于Django、Gunicorn和Nginx的全栈项目，是给朋友做的个人展示网站，用来分享专辑、摄影作品和文章动态。我用Django信号实现了两个自动化流程：

• 在管理后台上传格式规范的.docx文件后，自动填充模型实例的字段
• 删除模型实例（比如专辑、文章）时，同步删除服务器媒体文件夹里的对应文件

这套逻辑在开发环境里完全正常，还适配了多个模型，但部署到生产环境后出了问题：文件上传功能正常，但文件处理有时失效（导致字段为空），部分模型的文件删除功能完全用不了。

相关代码 #

settings.py #

INSTALLED_APPS = [
    'musicsite.apps.MusicsiteConfig',
    ...
]

apps.py #

from django.apps import AppConfig

class MusicsiteConfig(AppConfig):
    default_auto_field = 'django.db.models.BigAutoField'
    name = 'musicsite'

    def ready(self):
        from musicsite import signals

models.py #

class Bio(models.Model): 
    class Meta:
        verbose_name_plural = "Bio"
        
    italian_bio = models.TextField(*nothing important*)
    english_bio = models.TextField(*nothing important*)
    last_updated = models.DateField(auto_now=True)
    doc_file = models.FileField(upload_to="documents/", *nothing important*)

signals.py #

@receiver(pre_save, sender=Bio)
def replace_file(sender, instance, **kwargs):
    if not instance.pk:
        return
    try: 
        old_instance = Bio.objects.get(pk=instance.pk)
    except Bio.DoesNotExist:
        return
    old_doc_name = os.path.basename(old_instance.doc_file.name) if (old_doc := old_instance.doc_file) else None
    new_doc_name = os.path.basename(instance.doc_file.name) if (new_doc := instance.doc_file) else None
    
    if old_doc_name and (not new_doc_name or old_doc_name != new_doc_name):
        old_doc_path = Path(settings.MEDIA_ROOT) / old_doc.name
        if old_doc_path.is_file():
            safe_unlink(old_doc_path, retries=100)

@receiver(pre_delete, sender=Bio)
def delete_file(sender, instance, using, **kwargs):
    if instance.doc_file:
        doc_file_path = Path(settings.MEDIA_ROOT) / instance.doc_file.name
        if os.path.isfile(doc_file_path):
            safe_unlink(doc_file_path, retries=100)

@receiver(post_save, sender=Bio)
def process_biography_file(sender, instance, **kwargs):
    if hasattr(instance, '_disable_signals') and instance._disable_signals:
        return
    temp_it, temp_en = "", ""
    if instance.doc_file:
        full_path = Path(settings.MEDIA_ROOT) / instance.doc_file.name
        try:
            temp_data = handle_file(full_path)
            temp_it, temp_en = generate_biography(temp_data)
        except Exception as e:
            instance.delete()
            raise ValidationError(f"Error! {e}")
        with transaction.atomic():
            if instance.italian_bio == "":
                if temp_it != "":
                    instance.italian_bio = temp_it
                else:
                    instance.delete()
                    raise ValidationError("The italian field should not be empty!")
            if instance.english_bio == "":
                if temp_it != "":
                    instance.english_bio = temp_en
                else:
                    instance.delete()
                    raise ValidationError("The english field should not be empty!")
            # PREVENTS INFINITE RECURSION
            instance._disable_signals = True
            instance.save(update_fields=['italian_bio', 'english_bio',])
            instance._disable_signals = False
    else:
        if instance.italian_bio == "" or instance.english_bio == "":
            instance.delete()
            raise ValidationError("Fields cannot be empty! Upload a file or provide values for the admin fields!")

1. 生产环境信号注册可靠性 #

Gunicorn多worker模式下，ready()方法可能被重复调用，导致信号注册异常。可以：

• 确认INSTALLED_APPS配置的是musicsite.apps.MusicsiteConfig而非直接musicsite（当前配置已正确）
• 若仍有问题，将信号导入逻辑移至models.py末尾，避免多worker重复注册冲突

2. 媒体文件权限问题 #

生产环境中Nginx/Gunicorn的运行用户（如www-data）可能没有媒体目录的读写权限：

• 执行命令修改权限：

  sudo chown -R www-data:www-data /path/to/your/media/directory
  sudo chmod -R 755 /path/to/your/media/directory
  

3. 信号与事务的冲突 #

post_save信号内的实例删除操作可能触发事务未提交的异常，建议：

• 将异常处理中的instance.delete()改为标记实例状态，或用transaction.on_commit()延迟执行文件处理：

  # 修改post_save内的文件处理逻辑
  try:
      temp_data = handle_file(full_path)
      temp_it, temp_en = generate_biography(temp_data)
  except Exception as e:
      transaction.on_commit(lambda: instance.delete())
      raise ValidationError(f"Error! {e}")
  

4. 文件删除逻辑的漏洞 #

• 高并发场景下，获取旧实例时需加锁避免数据不一致：

  # replace_file信号中修改旧实例获取逻辑
  old_instance = Bio.objects.select_for_update().get(pk=instance.pk)
  

• 用Path.exists()替代os.path.isfile()，兼容性更强：

  doc_file_path = Path(settings.MEDIA_ROOT) / instance.doc_file.name
  if doc_file_path.exists():
      safe_unlink(doc_file_path, retries=100)
  

5. 递归控制的隐患 #

用实例属性_disable_signals控制递归可能因序列化丢失属性，建议改用update_fields判断：

@receiver(post_save, sender=Bio)
def process_biography_file(sender, instance, update_fields=None, **kwargs):
    # 仅当更新字段不包含目标字段时执行
    if update_fields and set(update_fields) <= {'italian_bio', 'english_bio'}:
        return
    # 原有逻辑...

内容的提问来源于stack exchange，提问作者Michele Loriso