如何在Oracle SQL中解析BLOB存储的Celery Pickle序列化结果？

原因分析 #

Celery使用pickle将任务结果序列化为二进制字节流后存入Oracle的BLOB字段，这些二进制数据并非标准字符编码的文本内容。to_char(dbms_lob.substr(BLOB_FIELD))会尝试用数据库默认字符集解析二进制流，自然会出现乱码——因为pickle字节流和字符编码完全不匹配。

解决方案 #

方案1：继续用Python解析（推荐） #

这是Celery设计的标准使用方式，直接读取BLOB字段的二进制数据后用pickle.loads()解析，示例代码：

import cx_Oracle
import pickle

conn = cx_Oracle.connect("用户名/密码@数据库地址:端口/服务名")
cursor = conn.cursor()
cursor.execute("SELECT result FROM celery_taskmeta WHERE task_id = :tid", tid="你的任务ID")
blob_data = cursor.fetchone()[0].read()
result = pickle.loads(blob_data)
print(result)
conn.close()

方案2：转十六进制后在Python中解析（仅当必须从SQL取数据时） #

如果需要先通过SQL获取数据，可将BLOB转为十六进制字符串，再在Python中还原为字节解析：

SELECT rawtohex(dbms_lob.substr(result)) AS pickle_hex FROM celery_taskmeta WHERE task_id = '你的任务ID';

Python处理代码：

import pickle

hex_str = "从SQL查询得到的十六进制字符串"
result_bytes = bytes.fromhex(hex_str)
result = pickle.loads(result_bytes)
print(result)

方案3：改用JSON序列化（适合简单结果） #

修改Celery配置，将序列化方式改为JSON，这样BLOB中存储的是JSON文本，直接用to_char即可查看：

# Celery配置文件
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_ACCEPT_CONTENT = ['json']

之后查询SQL：

SELECT to_char(dbms_lob.substr(result)) AS task_result FROM celery_taskmeta WHERE task_id = '你的任务ID';

注意：JSON仅支持基本数据类型（字符串、数字、列表、字典等），无法序列化复杂Python对象，需根据任务结果类型选择。

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