本文导读

展开导读

文档首页/ 函数工作流 FunctionGraph/ 用户指南/ 配置函数/ 配置函数的触发器/ 使用DIS触发器

使用DIS触发器

更新时间：2025-05-27 GMT+08:00

查看PDF

本节介绍如何通过函数工作流控制台创建数据接入服务DIS触发器，实现使用系统内置的事件模板配置DIS事件，触发函数运行。

DIS触发器概述

数据接入服务DIS（Data Ingestion Service）为处理或分析流数据的自定义应用程序构建数据流管道，主要解决云服务外的数据实时传输到云服务内的问题。数据接入服务每小时可从多种数据源中连续捕获、传送和存储数TB数据。

使用DIS触发器可以将FunctionGraph函数配置为自动轮询流并处理新记录，例如网站点击流、财务交易记录、社交媒体源、IT日志和数据位置跟踪事件等。FunctionGraph会定期轮询DIS数据流中的新记录。

DIS触发器的事件格式

以下为DIS触发器的示例事件，具体参数解释参考表1。

{
    "ShardID": "shardId-0000000000",
    "Message": {
        "next_partition_cursor": "eyJnZXRJdGVyYXRvclBhcmFtIjp7InN0cmVhbS1uYW1lIjoiZGlzLXN3dGVzdCIsInBhcnRpdGlvbi1pZCI6InNoYXJkSWQtMDAwMDAwMDAwMCIsImN1cnNvci10eXBlIjoiVFJJTV9IT1JJWk9OIiwic3RhcnRpbmctc2VxdWVuY2UtbnVtYmVyIjoiNCJ9LCJnZW5lcmF0ZVRpbWVzdGFtcCI6MTUwOTYwNjM5MjE5MX0",
        "records": [
            {
                "partition_key": "shardId_0000000000",
                "data": "d2VsY29tZQ==",
                "sequence_number": "0"
            },
            {
                "partition_key": "shardId_0000000000",
                "data": "dXNpbmc=",
                "sequence_number": "1"
            },
            {
                "partition_key": "shardId_0000000000",
                "data": "RnVuY3Rpb25TdGFnZQ==",
                "sequence_number": "2"
            },
            {
                "partition_key": "shardId_0000000000",
                "data": "c2VydmljZQ==",
                "sequence_number": "3"
            }
        ],
        "millis_behind_latest": ""
    },
    "Tag": "latest",
    "StreamName": "dis-swtest"
}

表1 DIS示例事件参数说明
参数	类型	示例值	描述
ShardID	String	shardId-0000000000	数据下载分区的ID。
next_partition_cursor	String	参考示例代码	下一个分区的游标。
Records	Map	参考示例代码	存储在DIS通道中的数据单元。
partition_key	String	参考示例代码	分区键。
data	String	参考示例代码	数据块，由数据生产者添加到数据通道。
sequence_number	Int	参考示例代码	每个记录的唯一标识符，由DIS服务自动分配。
Tag	String	latest	通道的标签。
StreamName	String	dis-swtest	通道名称。

约束与限制

DIS触发器当前支持“华北-北京一”、“华北-北京四”、“华东-上海一”、“华东-上海二”、“华南-广州”、“中国-香港”、“亚太-新加坡”、“土耳其-伊斯坦布尔”区域使用。具体运行时函数是否支持使用请以控制台为准。
DIS触发器调用的请求正文有效负载大小为6M。

前提条件

函数及其配置：
- 已创建函数。
- 已配置函数的DIS委托权限，操作过程请参见配置函数的委托权限。
数据接入服务DIS：
已创建DIS接入通道，此处以dis-function为例，创建过程请参见创建DIS通道。

创建DIS触发器

登录函数工作流控制台，在左侧的导航栏选择“函数 > 函数列表”。
选择待配置的函数，单击进入函数详情页。
选择“设置 > 触发器”，单击“创建触发器”，弹出“创建触发器”对话框。

参考表2配置DIS触发器参数。

表2 DIS触发器参数说明
参数	说明	取值样例
触发器类型	必选参数。选择“数据接入服务 (DIS)”。	数据接入服务 (DIS)
通道名称	必选参数。选择已创建的DIS通道，支持选择普通通道和高级通道。若无接入通道，可单击“申请接入通道”完成创建，详情可参考开通DIS通道。	dis-function
起始位置	必选参数。选择数据流中开始读取数据的位置，起始位置对应DIS服务中的游标类型，用来选择从DIS通道中读取数据的位置，详情可参考：获取数据游标。起始位置有以下选择： TRIM_HORIZON：从最早被存储至分区的有效记录开始读取。例如，某租户使用DIS的通道，分别上传了三条数据A1，A2，A3。N天后（设定A1已过期，A2和A3仍在有效期范围内），该租户需要下载此三条数据，并选择了TRIM_HORIZON这种下载方式。那么用户可下载的数据将从A2开始读取。 latest：从分区中的最新记录开始读取，此参数可以保证总是读到分区中最新记录。	latest
最大字节数	必选参数。每次触发时通道单次请求的记录的最大字节数，只有当分区中单条记录小于该值，才能被获取。单位可选择KB或MB。通道类型为普通通道：单次请求的记录总大小不能超过1MB（不包含partitionKey数据大小），设置范围：0KB~1024KB（0MB~1MB）。通道类型为高级通道：单次请求的记录总大小不能超过5MB（不包含partitionKey数据大小），设置范围：0KB~5120KB（0MB~5MB）。	1 MB
拉取周期	必选参数。设置拉取流数据的周期，单位可选择秒或毫秒，设置范围：1ms~60000ms（1s~60s）。	30 秒
串行处理数据	必选参数。如果启用该选项，系统将在完成一次数据处理后，才获取下一次数据；否则只要到达拉取周期，系统就会获取数据进行处理。如果关闭该选项，如图1所示，可根据业务需要配置并发数（范围：1-80）。功能说明：控制DIS触发器异步调用函数的并发数，防止单个触发器流量较大导致单租户并发跑满，进而影响其他DIS触发器执行。（当前仅“北京四”区域支持该功能）图1 关闭“串行处理数据”	开启

单击“确定”，完成DIS触发器的创建。

修改DIS触发器配置

DIS触发器创建后，支持对部分参数进行修改。

返回函数工作流控制台，在左侧的导航栏选择“函数 > 函数列表”。
选择待配置的函数，单击进入函数详情页。
选择“设置 > 触发器”，单击DIS触发器上的“编辑”，弹出“创建触发器”对话框。
支持修改“最大字节数/批处理大小”、“拉取周期”、“串行处理数据”参数，修改完成后单击“确定”。

配置DIS测试事件触发函数

返回函数工作流控制台，在左侧的导航栏选择“函数 > 函数列表”。
选择待配置的函数，单击进入函数详情页。
在函数详情页，选择函数版本。
在“代码”页签下，单击“测试”，弹出“配置测试事件”对话框。

填写如表3所示测试信息后，单击“保存”。

表3 测试信息
参数	说明
配置测试事件	可创建新的测试事件也可编辑已有的测试事件。选择默认值：“创建新的测试事件”。
事件模板	选择"数据接入服务（DIS）"模板，使用系统内置dis事件模板。
事件名称	事件名称必须以大写或小写字母开头，支持字母（大写或小写），数字和下划线“_”（或中划线“-”），并以字母或数字结尾，长度为1-25个字符。例如输入“dis-123test”。
测试事件	自动加载系统内置dis事件模板，本例不做修改。

单击“测试”，可以得到函数运行结果，函数会返回输入DIS数据。

意见反馈

文档内容是否对您有帮助？

有帮助没帮助

提供反馈

提交成功！非常感谢您的反馈，我们会继续努力做到更好！您可在我的云声建议查看反馈及问题处理状态。

系统繁忙，请稍后重试

在使用文档中是否遇到以下问题

内容与产品页面不一致

内容不易理解

缺失示例代码

步骤不可操作

搜不到想要的内容

缺少最佳实践

意见反馈（选填）

0/500

请至少选择一项反馈信息并填写问题反馈

字符长度不能超过500

直接提交取消

如您有其它疑问，您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问