需要将dataframe存储到redis里,
使用pyarrow 处理,出现提示信息
import pyarrow as pa
def serialize_dataframe(df):
try:
content = pa.default_serialization_context().serialize(df)
return content
except Exception as e:
return None
这样写,出现提示信息
FutureWarning: 'pyarrow.default_serialization_context' is deprecated as of 2.0.0 and will be removed in a future version. Use p
ickle or the pyarrow IPC functionality instead.
推荐使用pickle.
content = pickle.dumps(df)
这样更方便
origin_data = pickle.loads(content)
使用loads就可以复原了
在网上常看到的解决方案,
redisConn.set("key", df.to_msgpack(compress='zlib'))
在pandas官方文档里面搜索可以发现,这个方案已经被移除了
版权声明：本文为lvluobo原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。