如何在Celery中完全关闭序列化？适配仅传ASCII字符串的Django应用

嘿，我刚好折腾过这个需求，其实Celery完全支持彻底关闭序列化，核心就是用Kombu自带的raw序列化器——它完全不会对数据做任何处理，直接按原始字节传输，刚好匹配你只传ASCII字符串的场景。下面给你一步步的实现示例和配置细节：

在你的Celery配置文件（比如项目根目录的celery.py，或者Django的settings.py里的Celery配置段），添加关键配置项：

注意：Celery版本不同配置前缀有差异，以下是两种版本的写法：

Celery 4.x及以下版本 #

# 任务发送时使用raw序列化器
CELERY_TASK_SERIALIZER = 'raw'
# 任务结果返回时使用raw序列化器（不需要返回结果可忽略）
CELERY_RESULT_SERIALIZER = 'raw'
# 限制Worker仅接收raw类型内容，避免触发其他序列化逻辑
CELERY_ACCEPT_CONTENT = ['raw']

Celery 5.x及以上版本 #

# 任务发送时使用raw序列化器
task_serializer = 'raw'
# 任务结果返回时使用raw序列化器（不需要返回结果可忽略）
result_serializer = 'raw'
# 限制Worker仅接收raw类型内容，避免触发其他序列化逻辑
accept_content = ['raw']

在你的Django业务代码（比如视图、模型方法里），调用Celery任务时直接传原始ASCII字符串就行，不需要任何额外序列化操作：

from myapp.tasks import process_ascii_message

# 直接传递ASCII字符串，Celery会用raw序列化器原样发送
process_ascii_message.delay("Hello from Django! This is pure ASCII content.")

你的Celery任务函数可以直接接收字符串参数，raw序列化器会把传输的字节原样解码成字符串（ASCII字节解码后就是原字符串，完全不会有修改）：

# myapp/tasks.py
from celery import shared_task

@shared_task
def process_ascii_message(raw_message):
    # raw_message就是你发送的原始ASCII字符串，无任何序列化处理痕迹
    print(f"Received unmodified message: {raw_message}")
    # 在这里执行你的业务逻辑
    return "Processing completed"

如果你不想全局启用raw序列化，只想给特定任务关闭序列化，可以在任务装饰器里单独指定：

@shared_task(serializer='raw', accept_content=['raw'])
def only_this_task_uses_raw(message):
    # 这个任务单独使用无序列化传输逻辑
    pass

• 确保你传输的确实是纯ASCII字符串，如果包含非ASCII字符，raw序列化器会直接按字节传输，Worker端解码时可能出现乱码（不过你已经明确只传ASCII，这个问题可以忽略）；
• 如果你不需要任务返回结果，可以把result_serializer相关配置去掉，但为了配置一致性建议统一设置。

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