如何将 python pandas.Dataframe 对象作为参数传递给 celery 任务？

Question

我想将 Pandas 数据帧对象作为参数传递给 celery 任务。有没有办法实现这一目标？我知道数据帧对象不是 JSON 可序列化的，因此不能用作基于我当前设置的参数。

Answer 1

看起来我可以使用该pandas.Dataframe.to_json()方法将给定的数据帧转换为 JSON。一旦我将 JSON 值传递给我的 celery 任务，我就可以使用该pd.read_json()方法取回我的pandas.Dataframe对象。

[1] https://pandas.pydata.org/pandas-docs/stable/generated/pandas.DataFrame.to_json.html

[2] https://pandas.pydata.org/pandas-docs/stable/generated/pandas.read_json.html