更新时间：2023-12-13 GMT+08:00
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
父主题： 元素列表
