检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
案例概述 场景介绍 该案例演示客户如何使用FunctionGraph 与IoTDA 服务组合，处理物联网设备上报以及设备状态变动的相关数据。物联网设备在IoTDA 平台进行管理，设备产生的数据可以从IoTDA直接流转触发FunctionGraph 的函数运行。用户可以根据需要编写函数处理这些数据。
完成后单击“保存”，保存快照式冷启动配置。 参考发布版本发布函数版本，发布版本时开启“快照式冷启动”，触发快照的自动化制作。 图3 发布新版本 等待快照制作完成（5分钟超时时间）。 图4 快照制作中 图5 快照制作成功 调用开启了快照式冷启动的Java函数，查看执行日志中的快照式冷启动信息，如图6所示。
机和所需的资源量，让请求延时更加平稳。 函数流 函数流是用来编排FunctionGraph函数的工具，可以将多个函数编排成一个协调多个分布式函数任务执行的工作流。 用户通过在可视化的编排页面，将事件触发器、函数和流程控制器通过连线关联在一个流程图中，每个节点的输出作为连线下一个节
关机节点：需要定时关闭的虚拟机。 使用函数处理IOT数据 该案例演示您如何使用FunctionGraph 与IotDA 服务组合，处理物联网设备上报以及设备状态变动的相关数据。物联网设备在IotDA 平台进行管理，设备产生的数据可以从IotDA直接流转触发FunctionGraph 的函数运行。用户可以根据需要编写函数处理这些数据。
DDS的触发使用过程请参考使用DDS触发器。 分布式消息服务 Kafka版 当向Kafka实例的Topic生产消息时，FunctionGraph会消费消息，触发函数以执行额外的工作（Kafka示例事件）。 分布式消息Kafka的触发使用过程请参见： 使用Kafka触发器。 使用开源Kafka触发器 分布式消息服务 RabbitMQ版
前提条件 函数及其配置： 已创建函数，创建过程请参见创建函数。 已配置函数的分布式消息服务DMS委托权限，委托的创建请参见配置函数的委托权限。 请参见配置网络开启函数访问VPC内资源的网络配置。 分布式消息服务Kafka： 已创建Kafka实例，创建操作请参见购买Kafka专享版实例。
图1 创建触发器 配置以下参数。 表1 EG触发器（RabbitMQ）参数说明 参数名称 参数说明 触发器类型 必选参数。 选择“分布式消息服务 RabbitMQ版 (HC.RABBITMQ)”。 触发器名称 必选参数。 触发器的名称。只能包含字母、数字、下划线和中划线。不能以数字、中划线开头。长度在
图1 创建触发器 配置以下参数。 表1 EG触发器（RocketMQ）参数说明 参数名称 参数说明 触发器类型 必选参数。 选择“分布式消息服务 RocketMQ版 (HC.ROCKETMQ)”。 触发器名称 必选参数。 触发器的名称。只能包含字母、数字、下划线和中划线。不能以数字、中划线开头。长度在
aph对Kafka实例中指定Topic的新消息进行定期轮询。FunctionGraph会将轮询得到的消息作为参数，用于调用相应函数。 分布式消息服务Kafka版与开源Kafka的差异说明，请参见Kafka与开源Kafka的差异。 约束与限制 开源Kafka触发器当前支持“华北-北
App应用的场景。 使用FunctionGraph函数对IoTDA中的设备坐标数据进行转换 本章节介绍如何使用函数结合IoTDA服务，将物联网设备上报以及设备状态变动的相关数据，流转至FunctionGraph触发函数运行并进行坐标转换（将WGS84坐标转为GCJ02坐标）。 适
息作为参数，用于调用相应函数。 关于分布式消息服务RabbitMQ触发器的事件源介绍，请参见支持的事件源。 约束与限制 分布式消息服务RabbitMQ触发器当前支持“华北-北京四”、“华北-乌兰察布二零一”、“华北-乌兰察布二零二”、“华东-上海一”、“亚太-曼谷”、“亚太-新加
66eb7a0ffa8d9c36870c6892_ttytytytytytyt 设备ID，用于唯一标识一个设备。在注册设备时直接指定，或者由物联网平台分配获得。由物联网平台分配时，生成规则为"product_id" + "_" + "node_id"拼接而成。 最大长度：256 node_id
使用以下触发器的函数默认为异步调用，且不可修改。 云审计服务（CTS） 文档数据库服务（DDS） 数据接入服务（DIS） 分布式消息服务 Kafka版（KAFKA） 分布式消息服务 RabbitMQ版（RABBITMQ） 开源Kafka（OPENSOURCEKAFKA） 云数据库 GeminiDB
创建函数流 函数流是一个面向无服务器计算领域，编排无服务器分布式应用的工作流服务。基于该服务，用户可以通过Low Code以及可视化的方式将多个独立的无服务器函数用顺序、分支、并行等方式轻松编排成一个完整的应用，并提供监控和管理平台，用于诊断和调试应用。 本章节主要介绍如何创建函
页面创建转发规则，也可以在FunctionGraph 创建 IoT触发器来实现。下面说明在IoTDA 页面创建转发规则。 在服务控制台左侧导航栏，选择“IoT物联网 > 设备接入”进入IoTDA控制台，单击IoTDA实例列表中实例名称“总览”页面，然后选择“规则 > 数据转发”，单击“创建规则”。 图2
可选操作，在开启“快照式冷启动”或“预留实例”功能时为必选。函数初始化入口为固定配置：com.huawei.yuanrong.function.Handler.initializer，如图12所示。 图12 函数初始化入口配置 开启预留实例或者快照式冷启动。 通过预留实例，或者快照式冷启动功能
模拟TIMER事件，触发函数。 分布式消息服务 Kafka版（KAFKA） 模拟Kafka事件，触发函数。 开源Kafka（OPENSOURCEKAFKA） 模拟开源Kafka事件，触发函数。 分布式消息服务 RabbitMQ版（RABBITMQ） 模拟RabbitMQ事件，触发函数。 分布式消息服务 RabbitMQ版（HC
了成功调用时的异步通知目标为函数A，当异步触发函数A并且执行成功后，则可能出现A>B>A......循环调用的情况。 使用异步配置通知分布式消息服务（RocketMQ）时，需要函数配置VPC且与通知的RocketMQ实例在同一个VPC中。同时，需要确保RocketMQ实例所在的安
不能以_sys_或空格开头，不能以空格结尾 可用UTF-8格式表示的字母（包含中文）、数字和空格，以及以下字符：_ . : = + - @ 128个字符以内且不与其他标签键重复 标签值 可以为空字符串 可用UTF-8格式表示的字母（包含中文）、数字、空格，以及以下字符：_ . :
数据接入服务（DIS）管理员，拥有该服务下的所有权限。 创建DIS触发器请参见使用DIS触发器。 暂不支持 使用分布式消息触发器 DMS ReadOnlyAccess 分布式消息服务（DMS）的只读权限。 dms:instance:get（查看实例详情） 配置跨域VPC访问 VPC Administrator
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
