FGS.DisEventMap
模型说明
FGS.DisEventMap元素用来创建函数工作流服务的DIS触发器资源。DIS触发器依赖数据接入服务DIS,通过DIS事件触发函数执行。创建DIS触发器需开通DIS服务,并为函数配置访问DIS服务的IAM委托。
模型属性
属性 |
是否必选 |
描述 |
---|---|---|
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 使用建议:采用默认配置 |
关联关系
关系说明 |
关联节点 |
---|---|
被包含关系 |
输出
无
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