send
产品支持情况
产品  | 
是否支持  | 
|---|---|
√  | 
|
√  | 
|
x  | 
|
x  | 
|
√  | 
|
√  | 
|
x  | 
 针对
功能说明
提供group内点对点通信发送数据的send功能。
函数原型
1 | def send(tensor, sr_tag, dest_rank, group = "hccl_world_group")  | 
参数说明
参数名  | 
输入/输出  | 
描述  | 
|---|---|---|
tensor  | 
输入  | 
TensorFlow的tensor类型。 针对 针对 针对 针对Atlas 300I Duo 推理卡,支持数据类型为:int8、uint8、int16、uint16、int32、uint32、int64、uint64、float16、float32、float64。  | 
sr_tag  | 
输入  | 
int类型。 消息标签,相同sr_tag的send/recv对可以收发数据。  | 
dest_rank  | 
输入  | 
int类型。 数据的目标节点,该rank是group中的rank id。  | 
group  | 
输入  | 
String类型,最大长度为128字节,含结束符。 group名称,可以为用户自定义group或者"hccl_world_group"。  | 
返回值
无。
约束说明
- 调用该接口的rank必须在当前接口入参group定义的范围内,不在此范围内的rank调用该接口会失败。
 - send和receive必须配对使用,即调用send接口后,需要等到与之配对的receive接口接收数据后,才可以进行下一个接口调用。
 
调用示例
以下仅为代码片段,不可执行,调用HCCL Python接口进行集合通信操作的完整示例可参见样例代码。
1 2 3 4 5  | from npu_bridge.hccl import hccl_ops tensor = tf.random_uniform((1, 3), minval=1, maxval=10, dtype=tf.float32) sr_tag = 0 dest_rank = 1 result = hccl_ops.send(tensor, sr_tag, dest_rank)  |