我有一个包含各种数据类型(字符串、整数等)的numpy数组。 我尝试将numpy数组分散到20个节点上： 样本数据从CSV文件中提取出来，然后放入一个称为" data“的numpy数组中。data = numpy.array(sample_data)rank = comm.Get_rank()
size = comm.Get_
浏览 19提问于2021-03-18得票数 0
1回答
我曾经处理过整数和其他数据类型，但由于字典可以包含任何内容，我不确定它是否可以作为一个numpy对象分散。下面是我尝试过的，但显然是行不通的。我不知道如何散布‘数据’，即使它是可能的，因为数据是一个字典。from mpi4py import MPIsize = comm.Get_size()
rank = comm.Get_rank
浏览 0提问于2019-04-02得票数 0
2回答
我有一个包含100,000个python对象的列表，我希望在mpi4py中分散和收集这些对象。当我尝试使用8个处理器时，我得到：当我尝试从列表中创建一个对象数组并使用聚集和散布时，我得到一个错误，基本上说明数组的数据类型</em
浏览 93提问于2018-06-19得票数 1
有人能告诉我为什么这个最小的工作示例抱怨TypeError: expected a writeable buffer object#!/usr/bin/env pythonrank = MPI.COMM_WORLD.Get_rank()
comm
浏览 7提问于2013-10-15得票数 2
回答已采纳
1回答
期望的行为：
我试图在不同的节点上获取不同长度的列表，在一个节点中收集它们，并让主节点将它们放在一个集合中。这个列表在每个节点中都被命名为rout_array。请注意，rout_array中的元素仅为整数，且在节点之间不唯一。当我的代码中没有字符串时，我不知道如何获得用于KeyError的'O'。所有列表都包含整数，numpy数组包含整数，而此处活动的唯一字典中只有用于键
浏览 2提问于2016-06-23得票数 6
回答已采纳
我是mpi4py的新手。我编写代码是为了由多个处理器处理一个大型的numpy数组data。由于我无法提供输入文件，所以我提到了data的形状。data的形状是3000015，它包含字符串类型的数据。from mpi4py import MPIimport datetime as dt
comm = MPI.COMM_
浏览 4提问于2016-08-11得票数 1
我需要发送3d numpy数组的子数组。但是将子数组直接传递给MPI.Send()失败，错误为：通过MPI.Datatype.Create_vector创建新的数据类型没有帮助目前，我通过将子数组复制到具有连续内存布局的临时数组来解决此问题。
问题是缓冲区往往非常大，它会吃掉所有的内存和可用的交换空间。我认为创建跨步<em
浏览 3提问于2015-12-17得票数 3
2回答
这是我在第0位的数据集，在将其转换为NumPy数组后，我想使用send将其发送到另一位。data = [['zzz', '2', '-1'], ['xxx', '5', '-99'], ['zzz', '2', '-1']] 在转换为NumPy数组时，我尝试了许多字符串数据类型，但都不起作用'S13&
浏览 33提问于2020-12-10得票数 1
我是MPI和mpi4py的新手。我对下面的代码有两个问题。例如，排名0的数据不打印，而另一个排名的None类型的数据打印。
浏览 0提问于2017-03-25得票数 1
我正在尝试使用NumPy的结构化数组在MPI4Py中发送和接收数据。下面是我的数组结构：我使用Sendrecv方法来交换数据，如下所示：KeyError: 'T{=l:f0:(5
浏览 0提问于2012-07-11得票数 5
回答已采纳
我正在尝试编写两个脚本，一个是master脚本，另一个是worker脚本，其中的master脚本将生成worker的多个进程，然后将一个numpy数组强制转换为worker spawns。通过查看mpi4py的在线(模糊)教程数量，我觉得我理解了这个概念，但我编写的任何测试代码都不会成功地将数组发送给工作者。我没有收到错误，但他们从来没有收到过数组。谁能给我一个清晰的例子，告诉我如何使用mpi4py
浏览 2提问于2013-12-18得票数 3
0]) // I want string更长:我问的原因是，python的list行为正确，并为各种元素保留数据类型，而numpy数组则转换为公共类型。>>> na = numpy.array(a) typ
浏览 0提问于2013-11-12得票数 2
回答已采纳
2回答
散布numpy数组的项
、、、
我有一个类似于下面的3维numpy数组： [3, 4]], [[9, 10],我想要做的是散布外部数组中包含的每个2D数组，以产生以下结果：
浏览 12提问于2018-03-01得票数 0
回答已采纳
2回答
MPI4PY大阵列散射产生死锁
、、、、
我试图分散一个大小数组(3,512,512,48,2)，在使用np.float64的三个进程之间使用双精度Scatter()的数据类型。# mpirun -np 3 python3 prog.pyfrom mpi4py import MPI
对于大数组，我必须使用Scatterv()函数。因此，下面是使用此函
浏览 1提问于2019-11-15得票数 1
回答已采纳
4回答
假设我有一个具有各种数字数据类型的NumPy结构化数组。作为一个基本例子，如何将其转换为常规的NumPy浮点数数组？从，我知道我可以但显然，这是缓慢的，因为您“将高效打包的NumPy数组
浏览 3提问于2014-10-03得票数 3
回答已采纳
2回答
我正在使用mpi4py来并行我的代码。我想在节点之间传递两个数据，一个整数和一个实数。我还想使用数组和大写的Send和Recv函数，它们更快。阅读一些教程，这似乎是可能的，但我找不到任何例子。以下是一个不起作用的简单版本：from mpi4py import MPIsize = comm.Get_size()
dt = num
浏览 3提问于2016-04-28得票数 3
回答已采纳
1回答
设置Rank 0: [1, 1, 1]减价后我应该这种情况下如果发送长度小于或等于505个元素的numpy数组，没有问题，但在此基础上，我得到以下输出：
[83621b291fb8:0111
浏览 1提问于2020-05-17得票数 5
回答已采纳
2回答
我正在尝试找出如何将两个函数应用于一个numpy数组，每个函数只对一半的值起作用。下面是我一直在尝试的代码 xs[xs<=center] = height*np.exp((-(xs[xs<=centerxs[xs>center] = height*1/(np.abs(1+((center-xs[xs>center])/(fwhh/2))**2))但是，
浏览 1提问于2011-12-19得票数 0
回答已采纳
<type 'numpy.string_'>和<type 'str'>类型之间有区别吗
浏览 0提问于2015-05-07得票数 23
回答已采纳
我使用mpi4py来并行化我的Python应用程序。我注意到，每当我过多地增加进程数量或所涉及的数组大小时，我都会在MPI.Gather期间遇到死锁。示例：RANK = COMM.Get_rank()
SIZE = COMM.Get_size但是，如果我将数组维度更改为(10, 400, 15)，或者使用-n 2运行脚本，则一切都按预期工
浏览 0提问于2019-02-21得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
