-
QQ邮箱 - 应用与数据集成平台 ROMA Connect
在左侧导航栏选择“连接器”,在连接器页面单击“新建连接”。 选择“QQ邮箱”连接器。 在弹窗中配置连接器信息,完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 邮箱地址 发件人的QQ邮箱地址。 授权码 发件人的QQ邮箱授权码,可在QQ邮箱个人中心的设置中获取。具体操作请参考配置QQ邮箱授权码。
-
配置任务基本信息 - 应用与数据集成平台 ROMA Connect
选择“不使用”。 单位 任务执行周期的单位,与“调度周期”配合使用,可设置为“分”、“时”、“日”、“周”或“月”。 调度周期 任务执行周期,根据“单位”选择的不同,可设置值的范围不同。 例如“单位”选择“日”,“调度周期”设置为“1”,则表示数据集成任务每天执行一次。 生效时间 任务的开始执行时间。
-
查询Topic列表 - 应用与数据集成平台 ROMA Connect
请求参数 表3 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 响应参数 状态码: 200 表4 响应Body参数 参数 参数类型
-
创建Topic - 应用与数据集成平台 ROMA Connect
请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 表3 请求Body参数 参数 是否必选 参数类型 描述 name
-
配置映射规则 - 应用与数据集成平台 ROMA Connect
脚本模式 可通过编辑JavaScript脚本来配置源端数据(sourceObj指源表的字段集合对象)和目标端数据(targetObj指目标表的字段集合对象)的Mapping映射关系信息,增强复杂对象的Mapping处理能力。 脚本映射样例: 样例模板。 function excute(sourceObj){
-
接入Modbus协议设备 - 应用与数据集成平台 ROMA Connect
用户设备端寄存器地址由起始地址编号和功能码决定。 Modbus协议定义了设备地址(即起始地址)范围是0到65535,而寄存器地址是从1开始,范围为1到65536,所以如果起始地址为5,则对应的寄存器地址为6。 目前功能码仅支持01、02、03、04,对应寄存器地址范围如下: 功
-
配置示例 - 应用与数据集成平台 ROMA Connect
配置示例 前提条件 已获取IAM和ROMA Connect服务所在区域的Endpoint地址。 已获取ROMA Connect实例的实例ID,以及实例所在区域的项目ID。 在调用ROMA Connect的接口时,需要为调用请求添加认证信息。有Token认证和AK/SK认证两种认证
-
扩大资源配额 - 应用与数据集成平台 ROMA Connect
表1 申请扩大实例配额 参数 配置说明 区域 选择需要扩大实例配额的ROMA Connect服务所在区域。 问题描述 对申请扩大实例配额的需求进行描述,例如“申请扩大ROMA Connect服务实例配额”。 机密信息 保持默认选择,即“暂不输入”。 联系方式 保持默认选择,即“手机”和“邮箱”同时勾选。
-
KafkaConsumer类说明 - 应用与数据集成平台 ROMA Connect
res.push(iter.next()) } return JSON.stringify(res); } 构造器详情 public KafkaConsumer(Map configs) 构造一个Kafka消息消费者 参数:configs表示Kafka的配置信息
-
查询API详情 - 应用与数据集成平台 ROMA Connect
String 函数别名URN 当函数别名URN和函数版本同时传入时,函数版本将被忽略,只会使用函数别名URN timeout Integer 服务集成请求后端服务的超时时间。最大超时时间可通过实例特性backend_timeout配置修改,可修改的上限为600000 单位:毫秒。 最小值:1
-
配置调用授权(可选) - 应用与数据集成平台 ROMA Connect
API授权环境 选择要授权的API发布环境。 授权凭据 勾选要授予权限的凭据。 访问参数 为授权的凭据设置访问参数。访问参数会被添加到后端签名认证信息中,并发送给后端服务,后端服务根据携带的访问参数返回不同的响应参数。 绿色通道 开启绿色通道后,白名单地址中的客户端无需认证即可调用API。
-
并行处理 - 应用与数据集成平台 ROMA Connect
该分支的任务将被丢弃,且最终的合并结果中不会包含该分支。 超时时间为0时,表示不设置超时时间,将等待所有分支任务执行完成。 “并行处理”节点的分支名称,需在后续相邻节点的连线上配置。 父主题: 处理器
-
调用API时报“No backend available”错误 - 应用与数据集成平台 ROMA Connect
available”错误 原因分析 可能是以下两种原因导致,请逐一排查: 后端服务无法访问。 ECS安全组未开放需要的端口。 解决方案 请修改后端服务。 修改ECS安全组配置,开放需要的端口。 父主题: 服务集成
-
Java客户端使用说明 - 应用与数据集成平台 ROMA Connect
####################### #如果不使用SASL认证,以下参数请注释掉。 ####################### #设置jaas账号和密码,通过控制台设置 sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule
-
配置调用授权(可选) - 应用与数据集成平台 ROMA Connect
API授权环境 选择要授权的API发布环境。 授权凭据 勾选要授予权限的凭据。 访问参数 为授权的凭据设置访问参数。访问参数会被添加到后端签名认证信息中,并发送给后端服务,后端服务根据携带的访问参数返回不同的响应参数。 绿色通道 开启绿色通道后,白名单地址中的客户端无需认证即可调用API。
-
配置调用授权(可选) - 应用与数据集成平台 ROMA Connect
API授权环境 选择要授权的API发布环境。 授权凭据 勾选要授予权限的凭据。 访问参数 为授权的凭据设置访问参数。访问参数会被添加到后端签名认证信息中,并发送给后端服务,后端服务根据携带的访问参数返回不同的响应参数。 绿色通道 开启绿色通道后,白名单地址中的客户端无需认证即可调用API。
-
查看消息内容 - 应用与数据集成平台 ROMA Connect
您也可以单击“高级搜索”,设置查询条件,然后单击“搜索”,查询消息。 查询方式:选择消息的查询方式。 按生产时间查询:按生产消息的时间查询。 按偏移量查询:按分区中记录消息的位置查询。 实例节点出现故障的情况下,若Topic中的数据量比较大,单副本Topic查询消息时会出现内部服务错误问题,建议根据数据量适当减小查询时间范围。
-
配置Kafka日志推送策略 - 应用与数据集成平台 ROMA Connect
创建Kafka日志推送策略 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“服务集成 APIC > API策略”,在“策略管理”页签下单击“创建策略”。 在选择策略类型弹窗中选择“插件策略 > Kafka日志推送”。 在配置策略弹窗中配置插件策略信息。
-
配置系统间数据集成 - 应用与数据集成平台 ROMA Connect
数据根字段 指从源端获取到的JSON或XML格式数据中,元数据集上层公共字段的路径。此处不设置。 数据类型 选择从Kafka数据源获取的数据格式类型,需要与Kafka实际存储的数据格式一致。 消费偏移设置 选择集成最早获取的消息数据还是最新获取的消息数据。 元数据 指从源端获取到的JSO
-
附录:订阅的通知消息报文 - 应用与数据集成平台 ROMA Connect
"TAGS":"null" // 消息标签 } 普通设备/网关设备时,gatewayId和gatewayIdentifier的值设置为null。 网关子设备时,gatewayId和gatewayIdentifier分别为其网关设备的deviceId和deviceIdentifier。