更新时间:2023-04-20 GMT+08:00
分享

FGS.DisEventMap

模型说明

FGS.DisEventMap元素用来创建函数工作流服务的DIS触发器资源。DIS触发器依赖数据接入服务DIS,通过DIS事件触发函数执行。创建DIS触发器需开通DIS服务,并为函数配置访问DIS服务的IAM委托。

模型属性

表1 模型定义属性说明

属性

是否必选

描述

pollingInterval

拉取流数据的周期

参数类型:integer

取值说明:该字段为可选字段。当未配置该字段时,采用默认拉取流数据的周期30秒

默认值:30

取值约束:有效范围为1到60

使用建议:将该字段通过get_input函数传入,在AOS界面创建资源栈填写输入参数时可自动获取

batchSize

批处理大小

参数类型:integer

取值说明:当该字段未配置时,采用默认值100

默认值:100

取值约束:有效范围为1到10000

使用建议:将该字段通过get_input函数传入,在AOS界面创建资源栈填写输入参数时可自动获取

streamName

通道名称

参数类型:string

取值说明:该字段从已创建的DIS通道中获取

使用建议:将该字段通过get_input函数传入,在AOS界面创建资源栈填写输入参数时可自动获取

shardIteratorType

在流中开始读取数据的位置

参数类型:string

取值说明:支持TRIM_HORIZON,LATEST,当该字段未配置时,采用默认值TRIM_HORIZON

默认值:TRIM_HORIZON

取值约束:有效值为TRIM_HORIZON,LATEST

使用建议:将该字段通过get_input函数传入,在AOS界面创建资源栈填写输入参数时可自动获取

funcId

函数urn

参数类型:string

使用建议:采用默认配置

关联关系

表2 关联关系说明

关系说明

关联节点

被包含关系

FGS.Function

输出

blueprint样例

tosca_definitions_version: huaweicloud_tosca_version_1_0
inputs:
  fgsde1gr_streamName:
    description: 通道名称
    label: ''
  fgsfrgxk_codeType:
    description: 函数代码上传的类型
    label: ''
  fgsfrgxk_name:
    description: 函数名称
    label: ''
  fgsfrgxk_runtime:
    description: 函数的执行环境
    label: ''
node_templates:
  fgsde1gr:
    properties:
      funcId:
        get_reference: fgsfrgxk
      streamName:
        get_input: fgsde1gr_streamName
    requirements:
      - funcId:
          node: fgsfrgxk
    type: HuaweiCloud.FGS.DisEventMap
  fgsfrgxk:
    properties:
      code: >-
        exports.handler = function (event, context, callback) { const error =
        null; const output = `Hello message: ${JSON.stringify(event)}`;
        callback(error, output); }
      codeType:
        get_input: fgsfrgxk_codeType
      codeUrl: ''
      handler: index.handler
      memorySize: 128
      name:
        get_input: fgsfrgxk_name
      runtime:
        get_input: fgsfrgxk_runtime
      timeout: 3
      role: dis
    type: HuaweiCloud.FGS.Function

相关文档