如何解决通过快速延迟功能使用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}"
- 是否可以在dask中使用mpi?以及如何解决此错误?
- 如何从主存储器中获取数据而不是从文件中读取数据?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。