昇腾社区首页
中文
注册

aclnnPromptFlashAttentionV3

支持的产品型号

  • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件
  • Atlas 推理系列加速卡产品

功能说明

  • 算子功能:全量推理场景的FlashAttention算子,相较于aclnnPromptFlashAttentionV2接口,此接口新增了innerPrecise参数,用于支持高精度或者高性能模式选择。

  • 计算公式:

    self-attention(自注意力)利用输入样本自身的关系构建了一种注意力模型。其原理是假设有一个长度为n的输入样本序列x,x的每个元素都是一个d维向量,可以将每个d维向量看作一个token embedding,将这样一条序列经过3个权重矩阵变换得到3个维度为n*d的矩阵。

    self-attention的计算公式一般定义如下,其中Q、K、V为输入样本的重要属性元素,是输入样本经过空间变换得到,且可以统一到一个特征空间中。公式及算子名称中的"Attention"为"self-attention"的简写。

    Attention(Q,K,V)=Score(Q,K)VAttention(Q,K,V)=Score(Q,K)V

    本算子中Score函数采用Softmax函数,self-attention计算公式为:

    Attention(Q,K,V)=Softmax(QKTd)VAttention(Q,K,V)=Softmax(\frac{QK^T}{\sqrt{d}})V

    其中Q和KT的乘积代表输入x的注意力,为避免该值变得过大,通常除以d的开根号进行缩放,并对每行进行softmax归一化,与V相乘后得到一个n*d的矩阵。

函数原型

算子执行接口为两段式接口,必须先调用“aclnnPromptFlashAttentionV3GetWorkspaceSize”接口获取计算所需workspace大小以及包含了算子计算流程的执行器,再调用“aclnnPromptFlashAttentionV3”接口执行计算。

  • aclnnStatus aclnnPromptFlashAttentionV3GetWorkspaceSize(const aclTensor *query, const aclTensor *key, const aclTensor *value, const aclTensor *pseShift, const aclTensor *attenMask, const aclIntArray *actualSeqLengths, const aclIntArray *actualSeqLengthsKv, const aclTensor *deqScale1, const aclTensor *quantScale1, const aclTensor *deqScale2, const aclTensor *quantScale2, const aclTensor *quantOffset2, int64_t numHeads, double scaleValue, int64_t preTokens, int64_t nextTokens, char *inputLayout, int64_t numKeyValueHeads, int64_t sparseMode, int64_t innerPrecise, const aclTensor *attentionOut, uint64_t *workspaceSize, aclOpExecutor **executor)
  • aclnnStatus aclnnPromptFlashAttentionV3(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)

aclnnPromptFlashAttentionV3GetWorkspaceSize

  • 参数说明:

    • query(aclTensor*,计算输入):Device侧的aclTensor,公式中的输入Q,数据类型与key的数据类型需满足数据类型推导规则,即保持与key、value的数据类型一致。不支持非连续的Tensor数据格式支持ND。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持FLOAT16、BFLOAT16、INT8
      • Atlas 推理系列加速卡产品:数据类型仅支持FLOAT16
    • key(aclTensor*,计算输入):Device侧的aclTensor,公式中的输入K,数据类型与query的数据类型需满足数据类型推导规则,即保持与query、value的数据类型一致。不支持非连续的Tensor数据格式支持ND。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持FLOAT16、BFLOAT16、INT8
      • Atlas 推理系列加速卡产品:数据类型仅支持FLOAT16
    • value(aclTensor*,计算输入):Device侧的aclTensor,公式中的输入V,数据类型与query的数据类型需满足数据类型推导规则,即保持与query、key的数据类型一致。不支持非连续的Tensor数据格式支持ND。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持FLOAT16、BFLOAT16、INT8
      • Atlas 推理系列加速卡产品:数据类型仅支持FLOAT16
    • pseShift(aclTensor*,计算输入):Device侧的aclTensor,可选参数。不支持非连续的Tensor数据格式支持ND。输入shape类型需为(B, N, Q_S, KV_S)或(1, N, Q_S, KV_S),其中Q_S为query的shape中的S,KV_S为key和value的shape中的S。对于pseShift的KV_S为非32对齐的场景,建议padding到32字节来提高性能,多余部分的填充值不做要求。如不使用该功能时可传入nullptr。综合约束请见约束说明

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持FLOAT16、BFLOAT16,且在pseShift为FLOAT16类型时,要求此时的query为FLOAT16或INT8类型,而在pseShift为BFLOAT16类型时,要求此时的query为BFLOAT16类型。在query、key、value为FLOAT16且pseShift存在的情况下,默认走高精度模式
      • Atlas 推理系列加速卡产品:仅支持nullptr
    • attenMask(aclTensor*,计算输入):Device侧的aclTensor,代表下三角全为0上三角全为负无穷的倒三角mask矩阵,不支持非连续的Tensor数据格式支持ND。如果不使用该功能可传入nullptr。通常建议shape输入Q_S, KV_S; B, Q_S, KV_S; 1, Q_S, KV_S; B, 1, Q_S, KV_S; 1, 1, Q_S, KV_S,其中Q_S为query的shape中的S,KV_S为key和value的shape中的S,对于attenMask的KV_S为非32对齐的场景,建议padding到32对齐来提高性能,多余部分填充成1。综合约束请见约束说明

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持BOOL、INT8和UINT8
      • Atlas 推理系列加速卡产品:仅支持BOOL
    • actualSeqLengths(aclIntArray*,计算输入):Host侧的aclIntArray,用于表示不同Batch中query的有效序列长度。如果不指定序列长度,可以传入nullptr,这表示有效序列长度与query的shape中的S长度相同。需要注意的是,该参数中每个batch的有效序列长度不应超过query中对应batch的序列长度。

      • 关于seqlen的传入长度有以下规则:当传入长度为1时,所有Batch将使用相同的seqlen;当传入长度大于或等于Batch数量时,将取seqlen的前Batch个数值;其他长度的传入将不被支持。
      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持INT64,支持TND格式。当query的inputLayout为TND时,该入参必须传入,且以该入参元素的数量作为Batch值。该入参中每个元素的值表示当前Batch与之前所有Batch的Sequence Length和,因此后一个元素的值必须大于等于前一个元素的值,且不能出现负值
      • Atlas 推理系列加速卡产品:仅支持nullptr
    • actualSeqLengthsKv(aclIntArray*,计算输入):Host侧的aclIntArray,用于表示不同Batch中query的有效序列长度。如果不指定序列长度,可以传入nullptr,这表示有效序列长度与key/value的shape中的S长度相同。需要注意的是,该参数中每个batch的有效序列长度不应超过key/value中对应batch的序列长度。

      • 关于seqlen的传入长度有以下规则:当传入长度为1时,所有Batch将使用相同的seqlen;当传入长度大于或等于Batch数量时,将取seqlen的前Batch个数值;其他长度的传入将不被支持。
      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持INT64,支持TND格式。当key/value的inputLayout为TND时,该入参必须传入,且以该入参元素的数量作为Batch值。该入参中每个元素的值表示当前Batch与之前所有Batch的Sequence Length和,因此后一个元素的值必须大于等于前一个元素的值,且不能出现负值
      • Atlas 推理系列加速卡产品:仅支持nullptr
    • deqScale1(aclTensor*,计算输入):Device侧的aclTensor。数据格式支持ND,表示BMM1后面的反量化因子,支持per-tensor。 如不使用该功能时可传入nullptr。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持UINT64、FLOAT32
      • Atlas 推理系列加速卡产品:仅支持nullptr
    • quantScale1(aclTensor*,计算输入):Device侧的aclTensor。数据格式支持ND,表示BMM2前面的量化因子,支持per-tensor。 如不使用该功能时可传入nullptr。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持FLOAT32
      • Atlas 推理系列加速卡产品:仅支持nullptr
    • deqScale2(aclTensor*,计算输入):Device侧的aclTensor。数据格式支持ND,表示BMM2后面的反量化因子,支持per-tensor。 如不使用该功能时可传入nullptr。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持UINT64、FLOAT32
      • Atlas 推理系列加速卡产品:仅支持nullptr
    • quantScale2(aclTensor*,计算输入):Device侧的aclTensor。数据格式支持ND,表示输出的量化因子,支持per-tensor,per-channel。 如不使用该功能时可传入nullptr。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持FLOAT32和BFLOAT16
      • Atlas 推理系列加速卡产品:仅支持nullptr
    • quantOffset2(aclTensor*,计算输入):Device侧的aclTensor。数据格式支持ND,表示输出的量化偏移,支持per-tensor,per-channel。 如不使用该功能时可传入nullptr。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持FLOAT32和BFLOAT16
      • Atlas 推理系列加速卡产品:仅支持nullptr
    • numHeads(int64_t,计算输入):Host侧的int,代表query的head个数,数据类型支持INT64。

    • scaleValue(double,计算输入):Host侧的double,公式中d开根号的倒数,代表缩放系数,作为计算流中Muls的scalar值,数据类型支持DOUBLE。数据类型与query的数据类型需满足数据类型推导规则。用户不特意指定时建议传入1.0。

    • preTokens(int64_t,计算输入):Host侧的int,用于稀疏计算,表示attention需要和前几个Token计算关联。用户不特意指定时建议传入2147483647。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持INT64
      • Atlas 推理系列加速卡产品:仅支持取值2147483647
    • nextTokens(int64_t,计算输入):Host侧的int,用于稀疏计算,表示attention需要和后几个Token计算关联。用户不特意指定时建议传入0。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持INT64
      • Atlas 推理系列加速卡产品:仅支持取值0和2147483647
    • inputLayout(char*,计算输入):Host侧的字符指针CHAR*,用于标识输入query、key、value的数据排布格式,当前支持BSH、BSND、BNSD、BNSD_BSND(输入为BNSD时,输出格式为BSND)。用户不特意指定时建议传入"BSH"。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:除了上述格式,还支持TND(不支持pse、全量化、后量化)

      说明: query、key、value数据排布格式支持从多种维度解读,其中B(Batch)表示输入样本批量大小、S(Seq-Length)表示输入样本序列长度、H(Head-Size)表示隐藏层的大小、N(Head-Num)表示多头数、D(Head-Dim)表示隐藏层最小的单元尺寸,且满足D=H/N、T表示所有Batch输入样本序列长度的累加和。

    • numKeyValueHeads(int64_t,计算输入):Host侧的int,代表key、value中head个数,用于支持GQA(Grouped-Query Attention,分组查询注意力)场景。用户不特意指定时建议传入0,表示key/value和query的head个数相等。限制:需要满足numHeads整除numKeyValueHeads,numHeads与numKeyValueHeads的比值不能大于64,且在BSND、BNSD、BNSD_BSND场景下,需要与shape中的key/value的N轴shape值相同,否则报错。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持INT64
      • Atlas 推理系列加速卡产品:仅支持取值0
    • sparseMode(int64_t,计算输入):Host侧的int,表示sparse的模式。数据类型支持INT64。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件
        • sparseMode为0时,代表defaultMask模式,如果attenmask未传入则不做mask操作,忽略preTokens和nextTokens(内部赋值为INT_MAX);如果传入,则需要传入完整的attenmask矩阵(S1 * S2),表示preTokens和nextTokens之间的部分需要计算。
        • sparseMode为1时,代表allMask,必须传入完整的attenmask矩阵(S1 * S2)。
        • sparseMode为2时,代表leftUpCausal模式的mask,需要传入优化后的attenmask矩阵(2048*2048)。
        • sparseMode为3时,代表rightDownCausal模式的mask,对应以右顶点为划分的下三角场景,需要传入优化后的attenmask矩阵(2048*2048)。
        • sparseMode为4时,代表band模式的mask,需要传入优化后的attenmask矩阵(2048*2048)。
        • sparseMode为5、6、7、8时,分别代表prefix、global、dilated、block_local,均暂不支持。用户不特意指定时建议传入0。综合约束请见约束说明
      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:当inputLayout为TND时,sparseMode仅支持取值0、3。
      • Atlas 推理系列加速卡产品:仅支持取值0。
    • innerPrecise(int64_t,计算输入):Host侧的int,一共4种模式:0、1、2、3。一共两位bit位,第0位(bit0)表示高精度或者高性能选择,第1位(bit1)表示是否做行无效修正。数据类型支持INT64。Q_S>1时,sparse_mode为0或1,并传入用户自定义mask的情况下,建议开启行无效。综合约束请见约束说明

      • innerPrecise为0时,代表开启高精度模式,且不做行无效修正。

      • innerPrecise为1时,代表高性能模式,且不做行无效修正。

      • innerPrecise为2时,代表开启高精度模式,且做行无效修正。

      • innerPrecise为3时,代表高性能模式,且做行无效修正。

      说明: BFLOAT16和INT8不区分高精度和高性能,行无效修正对FLOAT16、BFLOAT16和INT8均生效。 当前0、1为保留配置值,当计算过程中“参与计算的mask部分”存在某整行全为1的情况时,精度可能会有损失。此时可以尝试将该参数配置为2或3来使能行无效功能以提升精度,但是该配置会导致性能下降。 如果算子可判断出存在无效行场景,会自动使能无效行计算,例如sparse_mode为3,Sq > Skv场景。

    • attentionOut(aclTensor*,计算输出):Device侧的aclTensor,公式中的输出。数据格式支持ND。限制:当inputLayout为BNSD_BSND时,输入query的shape是BNSD,输出shape为BSND;其余情况该入参的shape需要与入参query的shape保持一致。

      • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件:数据类型支持FLOAT16、BFLOAT16、INT8
      • Atlas 推理系列加速卡产品:仅支持FLOAT16
    • workspaceSize(uint64_t*,出参):返回用户需要在Device侧申请的workspace大小。

    • executor(aclOpExecutor**,出参):返回op执行器,包含了算子计算流程。

  • 返回值:

    返回aclnnStatus状态码,具体参见aclnn返回码

    第一段接口完成入参校验,若出现以下错误码,则对应原因为:
    -  返回161001(ACLNN_ERR_PARAM_NULLPTR):如果传入参数是必选输入,输出或者必选属性,且是空指针,则返回161001。
    -  返回161002(ACLNN_ERR_PARAM_INVALID):query、key、value、pseShift、attenMask、attentionOut的数据类型和数据格式不在支持的范围内。
    -  返回361001(ACLNN_ERR_RUNTIME_ERROR):API内存调用npu runtime的接口异常。

aclnnPromptFlashAttentionV3

  • 参数说明:

    • workspace(void*,入参):在Device侧申请的workspace内存地址。
    • workspaceSize(uint64_t,入参):在Device侧申请的workspace大小,由第一段接口aclnnPromptFlashAttentionV3GetWorkspaceSize获取。
    • executor(aclOpExecutor*,入参):op执行器,包含了算子计算流程。
    • stream(aclrtStream,入参):指定执行任务的AscendCL stream流。
  • 返回值:

    返回aclnnStatus状态码,具体参见aclnn返回码

约束说明

  • 该接口与PyTorch配合使用时,需要保证CANN相关包与PyTorch相关包的版本匹配。

  • 入参为空的处理:算子内部需要判断参数query是否为空,如果是空则直接返回。参数query不为空Tensor,参数key、value为空tensor(即S2为0),则attentionOut填充为全零。attentionOut为空Tensor时,AscendCLNN框架会处理。其余在上述参数说明中标注了"可传入nullptr"的入参为空指针时,不进行处理。

  • query,key,value输入,功能使用限制如下:

    • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件

      • 支持B轴小于等于65536(64k),输入类型包含INT8时D轴非32对齐或输入类型为FLOAT16或BFLOAT16时D轴非16对齐时,B轴仅支持到128;
      • 支持N轴小于等于256;
      • S支持小于等于20971520(20M)。部分长序列场景下,如果计算量过大可能会导致pfa算子执行超时(aicore error类型报错,errorStr为:timeout or trap error),此场景下建议做S切分处理,注:这里计算量会受B、S、N、D等的影响,值越大计算量越大。典型的会超时的长序列(即B、S、N、D的乘积较大)场景包括但不限于:
        • B=1,Q_N=20,Q_S=2097152,D=256,KV_N=1,KV_S=2097152;
        • B=1,Q_N=2,Q_S=20971520,D=256,KV_N=2,KV_S=20971520;
        • B=20,Q_N=1,Q_S=2097152,D=256,KV_N=1,KV_S=2097152;
        • B=1,Q_N=10,Q_S=2097152,D=512,KV_N=1,KV_S=2097152。
      • 支持D轴小于等于512。inputLayout为BSH或者BSND时,要求N*D小于65535。
    • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件: TND场景下query,key,value输入的综合限制:

      • T小于等于65536;
      • N等于8/16/32/64/128,且Q_N、K_N、V_N相等;
      • Q_D、K_D等于192,V_D等于128/192;
      • 数据类型仅支持BFLOAT16;
      • sparse模式仅支持sparse=0且不传mask,或sparse=3且传入mask;
      • 当sparse=3时,要求每个batch单独的actualSeqLengths < actualSeqLengthsKv。
    • Atlas 推理系列加速卡产品

      • 支持B轴小于等于128;
      • 支持N轴小于等于256;
      • 支持S轴小于等于65535(64k), Q_S或KV_S非128对齐,Q_S和KV_S不等长的场景不支持配置atten_mask;
      • 支持D轴小于等于512。
  • 参数sparseMode当前仅支持值为0、1、2、3、4的场景,取其它值时会报错。

    • Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件Atlas 推理系列加速卡产品
      • sparseMode = 0时,attenMask如果为空指针,则忽略入参preTokens、nextTokens(内部赋值为INT_MAX)。
      • sparseMode = 2、3、4时,attenMask的shape需要为S,S或1,S,S或1,1,S,S,其中S的值需要固定为2048,且需要用户保证传入的attenMask为下三角,不传入attenMask或者传入的shape不正确报错。
      • sparseMode = 1、2、3的场景忽略入参preTokens、nextTokens并按照相关规则赋值。
  • int8量化相关入参数量与输入、输出数据格式的综合限制:

    • 输入为INT8,输出为INT8的场景:入参deqScale1、quantScale1、deqScale2、quantScale2需要同时存在,quantOffset2可选,不传时默认为0。
    • 输入为INT8,输出为FLOAT16的场景:入参deqScale1、quantScale1、deqScale2需要同时存在,若存在入参quantOffset2 或 quantScale2(即不为nullptr),则报错并返回。
    • 输入为FLOAT16或BFLOAT16,输出为INT8的场景:入参quantScale2需存在,quantOffset2可选,不传时默认为0,若存在入参deqScale1 或 quantScale1 或 deqScale2(即不为nullptr),则报错并返回。
    • 入参 quantScale2 和 quantOffset2 支持 per-tensor/per-channel 两种格式和 FLOAT32/BFLOAT16 两种数据类型。若传入 quantOffset2 ,需保证其类型和shape信息与 quantScale2 一致。当输入为BFLOAT16时,同时支持 FLOAT32和BFLOAT16 ,否则仅支持 FLOAT32 。per-channel 格式,当输出layout为BSH时,要求 quantScale2 所有维度的乘积等于H;其他layout要求乘积等于N*D。(建议输出layout为BSH时,quantScale2 shape传入[1,1,H]或[H];输出为BNSD时,建议传入[1,N,1,D]或[N,D];输出为BSND时,建议传入[1,1,N,D]或[N,D])
    • 输出为int8,quantScale2 和 quantOffset2 为 per-channel时,暂不支持左padding、Ring Attention或者D非32Byte对齐的场景。
    • 输出为int8时,暂不支持sparse为band且preTokens/nextTokens为负数。
  • pseShift功能使用限制如下:

    • 支持query数据类型为FLOAT16或BFLOAT16或INT8场景下使用该功能。
    • query数据类型为FLOAT16且pseShift存在时,强制走高精度模式,对应的限制继承自高精度模式的限制。
    • Q_S需大于等于query的S长度,KV_S需大于等于key的S长度。
  • 输出为INT8,入参quantOffset2传入非空指针和非空tensor值,并且sparseMode、preTokens和nextTokens满足以下条件,矩阵会存在某几行不参与计算的情况,导致计算结果误差,该场景会拦截(解决方案:如果希望该场景不被拦截,需要在PFA接口外部做后量化操作,不在PFA接口内部使能):

    • sparseMode = 0,attenMask如果非空指针,每个batch actualSeqLengths - actualSeqLengthsKV - preTokens > 0 或 nextTokens < 0 时,满足拦截条件
    • sparseMode = 1 或 2,不会出现满足拦截条件的情况
    • sparseMode = 3,每个batch actualSeqLengthsKV - actualSeqLengths < 0,满足拦截条件
    • sparseMode = 4,preTokens < 0 或 每个batch nextTokens + actualSeqLengthsKV - actualSeqLengths < 0 时,满足拦截条件

调用示例

示例代码如下,仅供参考,具体编译和执行过程请参考编译与运行样例

    #include <iostream>
    #include <vector>
    #include <math.h>
    #include <cstring>
    #include "acl/acl.h"
    #include "aclnnop/aclnn_prompt_flash_attention_v3.h"
     
    using namespace std;
     
    #define CHECK_RET(cond, return_expr) \
      do {                               \
        if (!(cond)) {                   \
          return_expr;                   \
        }                                \
      } while (0)
     
    #define LOG_PRINT(message, ...)     \
      do {                              \
        printf(message, ##__VA_ARGS__); \
      } while (0)
     
    int64_t GetShapeSize(const std::vector<int64_t>& shape) {
      int64_t shapeSize = 1;
      for (auto i : shape) {
        shapeSize *= i;
      }
      return shapeSize;
    }
     
    int Init(int32_t deviceId, aclrtStream* stream) {
      // 固定写法,AscendCL初始化
      auto ret = aclInit(nullptr);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclInit failed. ERROR: %d\n", ret); return ret);
      ret = aclrtSetDevice(deviceId);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSetDevice failed. ERROR: %d\n", ret); return ret);
      ret = aclrtCreateStream(stream);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtCreateStream failed. ERROR: %d\n", ret); return ret);
      return 0;
    }
     
    template <typename T>
    int CreateAclTensor(const std::vector<T>& hostData, const std::vector<int64_t>& shape, void** deviceAddr,
                        aclDataType dataType, aclTensor** tensor) {
      auto size = GetShapeSize(shape) * sizeof(T);
      // 调用aclrtMalloc申请device侧内存
      auto ret = aclrtMalloc(deviceAddr, size, ACL_MEM_MALLOC_HUGE_FIRST);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMalloc failed. ERROR: %d\n", ret); return ret);
      // 调用aclrtMemcpy将host侧数据拷贝到device侧内存上
      ret = aclrtMemcpy(*deviceAddr, size, hostData.data(), size, ACL_MEMCPY_HOST_TO_DEVICE);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtMemcpy failed. ERROR: %d\n", ret); return ret);
     
      // 计算连续tensor的strides
      std::vector<int64_t> strides(shape.size(), 1);
      for (int64_t i = shape.size() - 2; i >= 0; i--) {
        strides[i] = shape[i + 1] * strides[i + 1];
      }
     
      // 调用aclCreateTensor接口创建aclTensor
      *tensor = aclCreateTensor(shape.data(), shape.size(), dataType, strides.data(), 0, aclFormat::ACL_FORMAT_ND,
                                shape.data(), shape.size(), *deviceAddr);
      return 0;
    }
     
    int main() {
      // 1. (固定写法)device/stream初始化,参考AscendCL对外接口列表
      // 根据自己的实际device填写deviceId
      int32_t deviceId = 0;
      aclrtStream stream;
      auto ret = Init(deviceId, &stream);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("Init acl failed. ERROR: %d\n", ret); return ret);
     
      // 2. 构造输入与输出,需要根据API的接口自定义构造
      int32_t batchSize = 1;
      int32_t numHeads = 2;
      int32_t sequenceLengthQ = 1;
      int32_t headDims = 16;
      int32_t keyNumHeads = 2;
      int32_t sequenceLengthKV = 16;
      std::vector<int64_t> queryShape = {batchSize, numHeads, sequenceLengthQ, headDims}; // BNSD
      std::vector<int64_t> keyShape = {batchSize, keyNumHeads, sequenceLengthKV, headDims}; // BNSD
      std::vector<int64_t> valueShape = {batchSize, keyNumHeads, sequenceLengthKV, headDims}; // BNSD
      std::vector<int64_t> attenShape = {batchSize, 1, 1, sequenceLengthKV}; // B11S
      std::vector<int64_t> outShape = {batchSize, numHeads, sequenceLengthQ, headDims}; // BNSD
      void *queryDeviceAddr = nullptr;
      void *keyDeviceAddr = nullptr;
      void *valueDeviceAddr = nullptr;
      void *attenDeviceAddr = nullptr;
      void *outDeviceAddr = nullptr;
      aclTensor *queryTensor = nullptr;
      aclTensor *keyTensor = nullptr;
      aclTensor *valueTensor = nullptr;
      aclTensor *attenTensor = nullptr;
      aclTensor *outTensor = nullptr;
      std::vector<float> queryHostData(batchSize * numHeads * sequenceLengthQ * headDims, 1.0f);
      std::vector<float> keyHostData(batchSize * keyNumHeads * sequenceLengthKV * headDims, 1.0f);
      std::vector<float> valueHostData(batchSize * keyNumHeads * sequenceLengthKV * headDims, 1.0f);
      std::vector<int8_t> attenHostData(batchSize * sequenceLengthKV, 0);
      std::vector<float> outHostData(batchSize * numHeads * sequenceLengthQ * headDims, 1.0f);
     
      // 创建query aclTensor
      ret = CreateAclTensor(queryHostData, queryShape, &queryDeviceAddr, aclDataType::ACL_FLOAT16, &queryTensor);
      CHECK_RET(ret == ACL_SUCCESS, return ret);
      // 创建key aclTensor
      ret = CreateAclTensor(keyHostData, keyShape, &keyDeviceAddr, aclDataType::ACL_FLOAT16, &keyTensor);
      CHECK_RET(ret == ACL_SUCCESS, return ret);
      // 创建value aclTensor
      ret = CreateAclTensor(valueHostData, valueShape, &valueDeviceAddr, aclDataType::ACL_FLOAT16, &valueTensor);
      CHECK_RET(ret == ACL_SUCCESS, return ret);
      // 创建atten aclTensor
      ret = CreateAclTensor(attenHostData, attenShape, &attenDeviceAddr, aclDataType::ACL_BOOL, &attenTensor);
      CHECK_RET(ret == ACL_SUCCESS, return ret);
      // 创建out aclTensor
      ret = CreateAclTensor(outHostData, outShape, &outDeviceAddr, aclDataType::ACL_FLOAT16, &outTensor);
      CHECK_RET(ret == ACL_SUCCESS, return ret);
      
      std::vector<int64_t> actualSeqlenVector = {sequenceLengthKV};
      auto actualSeqLengths = aclCreateIntArray(actualSeqlenVector.data(), actualSeqlenVector.size());
      
      int64_t numKeyValueHeads = numHeads;
      double scaleValue = 1 / sqrt(headDims); // 1/sqrt(d)
      int64_t preTokens = 65535;
      int64_t nextTokens = 65535;
      string sLayerOut = "BNSD";
      char layerOut[sLayerOut.length()];
      strcpy(layerOut, sLayerOut.c_str());
      int64_t sparseMode = 0;
      int64_t innerPrecise = 1;
      // 3. 调用CANN算子库API
      uint64_t workspaceSize = 0;
      aclOpExecutor* executor;
      // 调用第一段接口
      ret = aclnnPromptFlashAttentionV3GetWorkspaceSize(queryTensor, keyTensor, valueTensor, nullptr, nullptr, nullptr, nullptr, nullptr, nullptr, nullptr, nullptr, nullptr, 
        numHeads, scaleValue, preTokens, nextTokens, layerOut, numKeyValueHeads, sparseMode, innerPrecise, outTensor, &workspaceSize, &executor);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnPromptFlashAttentionV3GetWorkspaceSize failed. ERROR: %d\n", ret); return ret);
      // 根据第一段接口计算出的workspaceSize申请device内存
      void* workspaceAddr = nullptr;
      if (workspaceSize > 0) {
        ret = aclrtMalloc(&workspaceAddr, workspaceSize, ACL_MEM_MALLOC_HUGE_FIRST);
        CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("allocate workspace failed. ERROR: %d\n", ret); return ret);
      }
      // 调用第二段接口
      ret = aclnnPromptFlashAttentionV3(workspaceAddr, workspaceSize, executor, stream);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclnnPromptFlashAttentionV3 failed. ERROR: %d\n", ret); return ret);
     
      // 4. (固定写法)同步等待任务执行结束
      ret = aclrtSynchronizeStream(stream);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("aclrtSynchronizeStream failed. ERROR: %d\n", ret); return ret);
     
      // 5. 获取输出的值,将device侧内存上的结果拷贝至host侧,需要根据具体API的接口定义修改
      auto size = GetShapeSize(outShape);
      std::vector<double> resultData(size, 0);
      ret = aclrtMemcpy(resultData.data(), resultData.size() * sizeof(resultData[0]), outDeviceAddr,
                        size * sizeof(resultData[0]), ACL_MEMCPY_DEVICE_TO_HOST);
      CHECK_RET(ret == ACL_SUCCESS, LOG_PRINT("copy result from device to host failed. ERROR: %d\n", ret); return ret);
      for (int64_t i = 0; i < size; i++) {
        LOG_PRINT("result[%ld] is: %f\n", i, resultData[i]);
      }
     
      // 6. 释放资源
      aclDestroyTensor(queryTensor);
      aclDestroyTensor(keyTensor);
      aclDestroyTensor(valueTensor);
      aclDestroyTensor(attenTensor);
      aclDestroyTensor(outTensor);
      aclDestroyIntArray(actualSeqLengths);
      aclrtFree(queryDeviceAddr);
      aclrtFree(keyDeviceAddr);
      aclrtFree(valueDeviceAddr);
      aclrtFree(attenDeviceAddr);
      aclrtFree(outDeviceAddr);
      if (workspaceSize > 0) {
        aclrtFree(workspaceAddr);
      }
      aclrtDestroyStream(stream);
      aclrtResetDevice(deviceId);
      aclFinalize();
      return 0;
    }
    ```