文档首页/ 函数工作流 FunctionGraph/ 用户指南/ 配置函数/ 配置函数的触发器/ 使用云数据库GeminiDB DynamoDB触发器
更新时间：2025-09-08 GMT+08:00
查看PDF
分享

使用云数据库GeminiDB DynamoDB触发器

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

云数据库GeminiDB DynamoDB触发器触发事件说明

GeminiDB推出了兼容DynamoDB API的服务，用户可以通过SDK/CLI访问数据库服务。关于GeminiDB兼容DynamoDB接口的详细介绍请参考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触发器当前支持“华北-北京四”。具体运行时函数是否支持使用请以控制台为准。
  • 当前默认为每个DynamoDB实例上的每个表对应的流创建最多四个触发器。同一个FunctionGraph函数可以支持由不同表创建的多个DynamoDB触发器，但不允许由同一表创建多个DynamoDB触发器。
  • 如果执行函数返回函数错误，FunctionGraph不会重试，同时这部分数据将被丢弃。
  • 云数据库GeminiDB DynamoDB触发器调用的请求正文有效负载大小为6MB。

前提条件

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

创建GeminiDB DynamoDB触发器

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

    图1 创建触发器

  4. 参考表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

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

配置GeminiDB DynamoDB事件触发函数

  1. 返回函数工作流控制台，在左侧的导航栏选择“函数 > 函数列表”。
  2. 选择待配置的函数，单击函数名称进入函数详情页。
  3. 在函数详情页，选择函数版本。
  4. 在“代码”页签下，单击“测试”，弹出“配置测试事件”对话框。
  5. 填写如表3所示测试信息后，单击“保存”。

    表3 测试信息

    参数

    说明

    配置测试事件

    可创建新的测试事件也可编辑已有的测试事件。

    选择默认值：“创建新的测试事件”。

    事件模板

    选择空白模板，使用系统内置空白事件模板。

    事件名称

    事件名称必须以大写或小写字母开头，支持字母（大写或小写），数字和下划线“_”（或中划线“-”），并以字母或数字结尾，长度为1-25个字符，例如：Gemini-123test。

    测试事件

    自动加载系统内置空白事件模板，本例不做修改。

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

相关文档

除使用控制台外，函数工作流支持通过API的方式使用函数触发器，详情请参见函数触发器API参考。

父主题： 配置函数的触发器

相关文档