通过快速延迟功能使用mpi recv

问题描述

我正在尝试从mpi进程获取数据并使用dask处理该数据。为此，我创建了2个通信器，一个用于生产者进程，另一个用于dask-mpi，只有一位工人的排名=2。我从生产者进程发送了数据，并创建了一个调用mpi recv的函数，并尝试了在“延迟”中快速使用它。 在这种情况下，它会在recv调用时阻塞。

此后，我不得不通过actor中的方法使用mpi recv函数，但出现此错误：

"TypeError: ('Could not serialize object of type Intercomm.','<mpi4py.MPI.Intercomm object at 0x7fafc3b40e70>')
distributed.comm.utils - INFO - Unserializable Message: {'op': 'proxy','worker': 'tcp://192.168.8.101:39645','msg': {'function': 'recieve_data','actor': 'Acteur-91b37b9e-88e7-4e11-9e7d-fffb07b48a55','args': [<Serialize: <mpi4py.MPI.Intercomm object at 0x7fafc3b40e70>>],'kwargs': {},'op': 'actor_execute'},'reply': True}"

1. 是否可以在dask中使用mpi？以及如何解决此错误？
2. 如何从主存储器中获取数据而不是从文件中读取数据？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）