如何添加数据目的对应-阿里云帮助中心

IoT孪生引擎支持将指定孪生节点的属性变更Topic数据，流转至AMQP消费组和其他阿里云产品中。本文介绍添加数据目的对应的操作步骤。

使用限制

每个数据目的中最多添加一个转发操作。
每个数据目的中最多关联10个数据源。

创建数据目的

进入孪生空间页面。具体操作，请参见查看孪生空间。
在孪生空间页面左侧导航栏，单击数据流转。
单击数据目的页签。
单击创建数据目的。

在右侧面板，配置数据转发操作，单击确定。

参数	描述
数据目的名称	自定义名称。支持中文、英文字母、日文、数字、下划线（_）和短划线（-），长度为1~30个字符，一个中文及日文占2个字符。
数据目的描述	数据目的描述信息。
选择操作	设置数据转发目的地。可选：发布到AMQP服务端订阅消费组：将Topic数据转发到AMQP服务端订阅消费组，通过AMQP客户端消费消息。具体配置说明，请参见下文发布到AMQP服务端订阅消费组。发送数据到DataHub中：将Topic数据转发到DataHub上，再由DataHub将数据流转至实时计算、MaxCompute等服务中，以实现更多计算场景。具体配置说明，请参见下文发送数据到DataHub中。发送数据到消息队列（RocketMQ）中：将Topic数据转发到消息队列（RocketMQ）中存储，以实现消息从设备、物联网平台、RocketMQ到应用服务器之间的全链路高可靠传输能力。具体配置说明，请参见下文发布数据到消息队列（RocketMQ）中。发送数据到函数计算（FC）中：将Topic数据转发至函数计算（FC）中，然后由函数计算运行函数脚本进行业务处理。具体配置说明，请参见下文发布数据到函数计算（FC）中。发送数据到消息队列（Kafka）中：将Topic数据转发到消息队列（Kafka）中存储，从而实现消息从设备、物联网平台、Kafka到应用服务器之间的全链路高可靠传输能力。具体配置说明，请参见下文发送数据到消息队列（Kafka）中。
关联数据源	选择待转发的数据源。添加数据源操作，请参见添加待流转的数据源。您可在创建数据目的后，再关联数据源或更新已关联的数据源。具体操作，请参见更新数据目的关联的数据源。

发布到AMQP服务端订阅消费组

选择对应AMQP消费组。添加消费组操作，请参见创建消费组。

转发的数据目的配置完成后，需开发AMQP客户端接入物联网平台。

阿里云提供以下语言的AMQP客户端接入示例。示例中的参数配置，请参见连接配置说明。

重要建议您使用阿里云物联网平台提供的AMQP SDK接入示例。对于您自研的AMQP SDK，阿里云不提供后续技术支持服务。

发送数据到DataHub中

参数	说明
地域	选择DataHub所在地域。重要 DataHub Project所在地域，必须与当前IoT孪生引擎所属物联网平台实例的所在地域保持一致。
Project	选择DataHub Project。您可以单击创建Project，跳转到DataHub控制台，创建DataHub Project，请参见Project操作。
Topic	选择接收数据的DataHub Topic。选择Topic后，IoT孪生引擎会自动获取Topic中的Schema，IoT孪生引擎的孪生节点属性数据将会映射到对应的Schema中。说明将数据映射到Schema时，需使用`${}`，否则存入表中的将会是一个常量。 Schema与IoT孪生引擎的数据类型必须保持一致，否则无法存储。您可以单击创建Topic，跳转到DataHub控制台，创建DataHub Topic。
角色	授权物联网平台将数据写入DataHub。如您还未创建相关角色，单击创建RAM角色，跳转到RAM控制台，创建角色和授权策略，请参见创建RAM角色。

发布数据到消息队列（RocketMQ）中

参数	说明
地域	选择RocketMQ所在地域。重要 RocketMQ实例所在地域，必须与当前IoT孪生引擎所属物联网平台实例的所在地域保持一致。
实例	选择RocketMQ实例。您可以单击创建实例，跳转到消息队列控制台，创建RocketMQ实例，请参见消息队列文档。
Topic	选择用于接收IoT孪生引擎数据的RocketMQ Topic。您可以单击创建Topic，跳转到消息队列控制台，创建RocketMQ Topic。
授权	授权物联网平台将IoT孪生引擎数据写入RocketMQ。如您还未创建相关角色，单击创建RAM角色，跳转到RAM控制台，创建角色和授权策略，请参见创建RAM角色。

说明

当使用RocketMQ 5.0时，转发的数据目的配置完成后，会自动完成以下配置，实现IoT孪生引擎数据转发到消息队列RocketMQ。

物联网平台占用RocketMQ实例所在虚拟交换机的2个IP地址。
在RocketMQ实例所在的VPC网络下创建托管安全组，安全组名称默认以sg-nsm-开头。

发布数据到函数计算（FC）中

参数	说明
地域	选择函数计算所在地域。重要函数计算的服务和函数所在地域，必须与当前IoT孪生引擎所属企业版实例所在地域保持一致。
服务	选择函数计算服务。您可单击创建服务，跳转到函数计算控制台创建服务。服务的详细说明，请参见管理服务。
函数版本选择方式	可选：使用默认版本：使用函数计算的默认版本LATEST。选择版本：选择您为函数计算服务发布的版本。您可单击创建版本，跳转到函数控制台创建版本。版本的详细内容，请参见管理版本。选择别名：选择您为函数计算服务版本设置的别名。您可单击创建别名，跳转到函数控制台创建别名。别名的详细内容，请参见管理别名。
函数	选择接收数据的函数。您可以单击创建函数，跳转到函数计算控制台创建函数。函数的详细说明，请参见管理函数。重要创建函数中的请求处理程序类型仅支持选择处理事件请求。
授权	授权物联网平台将数据写入函数计算。如您还未创建相关角色，单击创建RAM角色，跳转到RAM控制台，创建角色和授权策略，请参见创建RAM角色。

发送数据到消息队列（Kafka）中

参数	描述
角色	授权物联网平台将数据写入Kafka。如您还未创建相关角色，单击创建RAM角色，跳转到RAM控制台，创建角色和授权策略，请参见创建RAM角色。
地域	固定为当前IoT孪生引擎所属企业版实例所在地域。
实例	选择Kafka实例。您可以单击创建实例，跳转到消息队列控制台，创建Kafka实例。具体操作，请参见创建实例。
Topic	选择用于接收IoT孪生引擎数据的Kafka Topic。您可以单击创建Topic，跳转到消息队列控制台，创建Kafka Topic。具体操作，请参见创建Topic。

说明

转发的数据目的配置完成后，会自动完成以下配置，实现IoT孪生引擎数据转发到消息队列（Kafka）。

物联网平台占用Kafka实例所在虚拟交换机的2个IP地址。
在Kafka实例所在的VPC网络下创建托管安全组，安全组名称默认以sg-nsm-开头。

其他操作

创建数据目的成功后，在数据目的页签的数据目的列表，找到对应数据目的，可执行以下操作。

操作

步骤

编辑

您可修改数据目的名称、描述、数据转发操作下的具体配置及更新关联的数据源。

单击数据目的对应操作列的编辑。
在编辑数据目的对话框，修改相关配置。
单击确定。

删除

警告

删除数据目的成功后，如果用户在其他业务中使用了流转的数据，会导致服务不可用或影响用户的业务。请谨慎操作。

删除数据目的会自动取消数据源关联关系。

说明

删除数据目的前，需先停止已关联数据源运行。具体操作，请参见设置已关联数据源的启停状态。

单击数据目的对应操作列的删除。
单击确认。