检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
设备集成指导 业务使用介绍 创建产品 注册设备 接入设备 产品管理 设备管理 规则引擎 订阅管理
Connect实例已绑定弹性IP，且本地PC所在网络与弹性IP的网络互通。 已在本地PC下载并安装Java JDK，并完成相关环境变量的配置。 根据ROMA Connect实例的Kafka版本，下载对应版本的开源Kafka命令行工具。您可以在ROMA Connect实例控制台的“实例信
Connect可以将这些数据以文本文件的形式存储在OBS中。 约束与限制 如果需要配置“异常数据存储”，请展开“异常数据存储”模块参照表1进行配置，如果不需要配置，请将“异常数据存储”模块折叠，否则影响任务保存。 配置异常数据存储 在配置异常数据存储前，您需要提前完成OBS数据源的接入配置，具体请参见接入OBS数据源。
String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 size Integer 本次返回的列表长度 total Long 满足条件的记录数 throttle_specials
采集技术模型 接入扩展采集器（可选） 接入数据源 创建采集任务 父主题： 应用业务模型使用指导
高吞吐量、低延迟的平台，可以处理大量的实时数据流。Kafka主要由三个部分组成：生产者、消费者和代理服务器。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是Kafka集群中的核心组件，负责处理消息的存储和转发。Kafka的主要优点是可扩展
高吞吐量、低延迟的平台，可以处理大量的实时数据流。Kafka主要由三个部分组成：生产者、消费者和代理服务器。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是Kafka集群中的核心组件，负责处理消息的存储和转发。Kafka的主要优点是可扩展
数据集成指导 业务使用介绍 接入数据源 创建数据集成任务（普通任务） 创建数据集成任务（组合任务） 创建数据集成任务（编排任务） 启停数据集成任务 数据集成任务管理 连接器
引用变量 在组合应用的流任务编排中，以及连接器和处理器配置中涉及到大量的输入输出信息，还涉及到大量的配置信息需要填写。用户在编辑设计组合应用时，可以通过变量的方式快速引用流任务中的输入输出信息和配置信息，帮助用户便捷高效的设计组合应用。 组合应用中的变量可以分为系统变量、节点变量
项目ID，获取方式请参见API参考的“附录 > 获取项目ID”章节。 instance_id 是 String 实例ID plugin_id 是 String 插件编号 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通
项目ID，获取方式请参见API参考的“附录 > 获取项目ID”章节。 最小长度：1 最大长度：64 instance_id 是 String 实例ID。 最小长度：1 最大长度：64 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Tok
API时的鉴权。 App Secret 接入密钥。创建消息&短信应用时，平台会自动生成APP_Key和APP_Secret，用于调用短信API时的鉴权。 描述 填写连接器的描述信息，用于识别不同的连接器。 支持的动作 发送短信 配置参数 参数 说明 区域 短息服务所在的区域。 项目
Connect实例中的资源都要归属到某个集成应用下，在创建其他资源前，您需要确保有一个集成应用。若已有可用的集成应用，可跳过此步骤。 登录ROMA Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。 在左侧的导航栏选择“集成应用”，单击页面右上角的“创建集成应用”。
合作伙伴之间的集成面临这些瓶颈： 地域差异 集团总部和集团子公司、合作伙伴所处的地域不同，时区不同，降低了数据的时效性和可靠性。 云服务差异 集团总部和集团子公司、合作伙伴使用的云服务不一样，调用不同的云服务存在困难。 网络差异 集团总部和集团子公司、合作伙伴使用的网络不一样，公网、专网、VPN之间的对接难度很高。
开放数据API 接入数据源 创建数据后端 发布数据API 绑定域名 配置调用授权（可选） 父主题： 服务集成指导
Connect根据您选择的实例规格和使用时长计费。 表1 ROMA Connect计费项 计费项 计费说明 ROMA Connect实例 根据实例规格，购买时长以及所购买的实例数量计费。 计费模式 ROMA Connect当前提供包周期（包年/包月）的计费模式，根据实例购买时长，一次性支付实例费用。
查询候选用户成员 功能介绍 查询应用的候选用户成员列表，会过滤掉异常状态用户。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v2/{project_id
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：100000 表3 请求Body参数 参数 是否必选 参数类型
项目ID，获取方式请参见API参考的“附录 > 获取项目ID”章节。 instance_id 是 String 实例ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取
gKey模糊匹配的Queue中。 void produceWithFanoutExchange(String props, String message) 用fanout交换器生产消息，把所有发送到该Exchange的消息路由到所有与它绑定的Queue中。 方法详情 public
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
