def receive(shape, data_type, sr_tag, src_rank, group = "hccl_world_group")
提供group内点对点通信发送数据的receive功能。
参数名 |
输入/输出 |
描述 |
|---|---|---|
shape |
输入 |
接收tensor的shape。 |
data_type |
输入 |
接收数据的数据类型。 针对Atlas 训练系列产品，tensor支持的数据类型为int8, uint8, uint16, int32, uint32, int64, uint64, float16, float32, float64。 |
sr_tag |
输入 |
int类型。 消息标签，相同sr_tag的send/recv对可以收发数据。 |
src_rank |
输入 |
int类型。 接收数据的源节点，该rank是group中的rank id。 |
group |
输入 |
String类型，最大长度为128字节，含结束符。 group名称，可以为用户自定义group或者"hccl_world_group"。 |
tensor：进行receive操作之后接收到对端的结果tensor。
from npu_bridge.npu_init import * sr_tag = 0 src_rank = 0 tensor = hccl_ops. receive (tensor.shape, tensor.dtype, sr_tag, src_rank)