在cythonized类中使用dask时,对象方法的pickling出错可能是由于dask无法正确序列化cythonized对象导致的。为了解决这个问题,可以尝试以下方法:
dask.delayed
装饰器:将需要在dask中使用的对象方法使用dask.delayed
装饰器进行修饰,将其延迟执行。这样可以避免直接对cythonized对象进行序列化和反序列化,从而解决pickling错误的问题。dask.distributed
:使用dask分布式模式,将任务分发给多个工作节点执行。在这种模式下,对象方法不需要进行序列化和反序列化,而是在工作节点上直接执行。可以使用dask.distributed.Client
来创建一个分布式客户端,并使用client.submit
方法提交任务。总结:在cythonized类中使用dask时,对象方法的pickling出错可能是由于dask无法正确序列化cythonized对象导致的。可以尝试使用dask.delayed
装饰器延迟执行方法、使用dask.distributed
进行分布式执行,或重新设计类的结构来解决该问题。
领取专属 10元无门槛券
手把手带您无忧上云