使用云数据库geminidb dynamodb触发器-j9九游会登录

本节介绍如何通过函数工作流控制台创建云数据库geminidb dynamodb触发器。

云数据库geminidb dynamodb触发器触发事件说明

geminidb推出了兼容dynamodb api的服务，用户可以通过sdk/cli访问数据库服务。关于geminidb兼容dynamodb接口的详细介绍请参考。

云数据库geminidb dynamodb作为事件源，通过geminidb dynamodb触发器可实现定时拉取dynamodb数据库流表信息，并触发函数执行。geminidb dynamodb触发器每秒轮询四次以查找新记录，当出现新的流记录时，将同步调用functiongraph函数。

云数据库geminidb dynamodb触发器的示例事件

以下为云数据库geminidb dynamodb触发器的示例事件，具体参数解释请参考表1。

{
     "event_time": 1747905781,
     "trigger_type": "dynamodb",
     "instance_ip": "10.0.0.205",
     "table_name": "test_052201",
     "records": [
         {
             "region": "ddbhws",
             "event_id": "000001747880625259000",
             "event_name": "insert",
             "sequence_number": "000001747880625259000",
             "size_bytes": 170,
             "stream_view_type": "new_and_old_images",
             "approximate_arrival_timestamp": "2025-05-22t02:23:45.259z",
             "keys": {
                 "title": {
                     "s": "test"
                 },
                 "year": {
                     "n": "2025"
                 }
             },
             "old_image": {
             },
             "new_image": {
                 "plot": {
                     "s": "plot"
                 },
                 "rating": {
                     "n": "1"
                 },
                 "title": {
                     "s": "test"
                 },
                 "year": {
                     "n": "2025"
                 }
             }
         },
         {
             "region": "ddbhws",
             "event_id": "000001747881021099000",
             "event_name": "modify",
             "sequence_number": "000001747881021099000",
             "size_bytes": 323,
             "stream_view_type": "new_and_old_images",
             "approximate_arrival_timestamp": "2025-05-22t02:30:21.099z",
             "keys": {
                 "title": {
                     "s": "test"
                 },
                 "year": {
                     "n": "2025"
                 }
             },
             "old_image": {
                 "plot": {
                     "s": "plot"
                 },
                 "rating": {
                     "n": "1"
                 },
                 "title": {
                     "s": "test"
                 },
                 "year": {
                     "n": "2025"
                 }
             },
             "new_image": {
                 "plot": {
                     "s": "plot"
                 },
                 "rating": {
                     "n": "2"
                 },
                 "title": {
                     "s": "test"
                 },
                 "year": {
                     "n": "2025"
                 }
             }
         }
     ]
 }

表1 geminidb dynamodb示例事件参数说明
参数	类型	示例值	描述
eventtime	int	1747905781	触发器拉取完消息时的时间。
triggertype	string	dynamodb	触发器类型。
instanceip	string	参考示例代码	dynamodb的实例ip。
tablename	string	参考示例代码	dynamodb的表名。
region	string	参考示例代码	局点信息。
eventid	string	参考示例代码	事件id。
eventname	string	insert \| modify \| remove	事件类名,枚举示例表示分别为插入，更改，删除。
sequencenumber	string	参考示例代码	事件序列号。
sizebytes	int	100	事件消息大小。
streamviewtype	string	new_image \| old_image \| new_and_old_images \| keys_only	记录方式，枚举示例表示分别为新镜像，旧镜像，新旧镜像，仅主键。
approximatearrivaltimestamp	string	参考示例代码	事件入库时间。
keys	map	参考示例代码	主键。
oldimage	map	参考示例代码	旧镜像。
newimage	map	参考示例代码	新镜像。

约束与限制

geminidb dynamodb触发器当前支持“华北-北京四”。具体运行时函数是否支持使用请以控制台为准。
geminidb dynamodb触发器支持使用的区域和具体运行时函数请以控制台展示为准。
当前默认为每个dynamodb实例上的每个表对应的流创建最多四个触发器。同一个functiongraph函数可以支持由不同表创建的多个dynamodb触发器，但不允许由同一表创建多个dynamodb触发器。
如果执行函数返回函数错误，functiongraph不会重试，同时这部分数据将被丢弃。
云数据库geminidb dynamodb触发器调用的请求正文有效负载大小为6mb。

前提条件

云数据库geminidb兼容dynamodb接口实例：
- 已创建geminidb兼容dynamodb接口实例，创建过程请参见。
- 请参见配置对应的安全组规则。

函数及其配置：
- 已创建函数。
- 已配置函数的vpc权限和“geminidb readonlyaccess”委托权限，详情请参见配置函数的委托权限。
- 已开启函数访问vpc内资源的网络配置，且为函数配置的vpc需要与云数据库实例配置中的vpc相同，详情请参见配置函数访问vpc。

创建geminidb dynamodb触发器

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

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

表2 geminidb dynamodb触发器参数说明
参数	说明	取值样例
触发器类型	必选参数。选择“云数据库 geminidb dynamodb(dynamodb)”。	云数据库 geminidb dynamodb(dynamodb)
名称	必填参数。填写触发器的名称。以中文或英文开头，可以包含中文、英文、数字、下划线及中划线，最大长度64位。	dynamodb-fg
实例	必选参数。选择已创建的geminidb dynamodb数据库实例。若无实例，可单击“创建实例”完成创建。	geminidb-fg
用户名	必填参数。填写dynamodb数据库用户名。只能包含英文字母、数字、下划线及中划线。	rwuser
密码	必填参数。填写dynamodb数据库密码。	geminidb-test
表名	必填参数。填写dynamodb数据库表名。只能包含英文字母、数字、下划线及中划线。	table-test
批处理大小	必选参数。输入每批从数据库读取的记录的数量，设置范围：1~10000。	100
起始位置	必选参数。选择流中开始读取数据的位置，有以下选项： trim_horizon：从最早被存储至分区的有效记录开始读取。 latest：从分区中的最新记录开始读取，此设置可以保证总是读到分区中最新记录。	trim_horizon

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

配置geminidb dynamodb事件触发函数

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

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

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

单击“测试”，可以得到函数运行结果。

意见反馈

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

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

系统繁忙，请稍后重试

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

内容与产品页面不一致

内容不易理解

缺失示例代码

步骤不可操作

搜不到想要的内容

缺少最佳实践

意见反馈（选填）

0/500

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

字符长度不能超过500

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