检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
创建组合应用 使用模板创建组合应用 组合应用模板 智能助手
上云下，消除数字鸿沟，实现数字化转型。 产品介绍 立即使用 成长地图 由浅入深，带您玩转ROMA Connect 01 了解 了解ROMA Connect的产品架构、功能和基础知识，有助于您快速准确的找到与实际业务匹配的功能。 产品介绍 什么是ROMA Connect ROMA Connect的使用场景
规则引擎 创建规则 查询规则 批量删除规则 调试规则 删除规则 查询规则详情 修改规则 添加目标数据源 查询目标数据源列表 删除目标数据源 添加源数据源 查询源数据源列表 删除源数据源 父主题： 设备集成API
先停止任务。 如果要集成同步的数据量较大，且任务的执行时间间隔较短，会出现上一次任务调度还没有执行完，下一次任务调度时间点已到的情况。此时ROMA Connect会暂停执行新的调度，等待上一次调度执行完成。 在创建任务页面中配置任务计划。ROMA Connect提供了两种配置任务计划的方式：
Kafka。第三方平台（比如DataArts Studio）可以通过订阅Kafka或MRS Kafka获取消息，并根据实际需要选择是否执行数据抽取任务。 本章节介绍任务执行完成后，如何配置消息发送，如果不需要发送消息可不配置。 前提条件 已经在对应的应用下创建Kafka和MRS Kafka数据源，数据
附录：QuartZ Cron表达式配置说明 参数说明 数据集成任务支持使用QuartZ Cron表达式配置定时任务的调度计划。 QuartZ Cron表达式由6个部分组成，每个部分使用空格隔开。表达式中的六个部分从左到右代表的含义如下： 秒 分 时 日 月 周 具体参数如表1所示。
参考步骤3添加目标端数据源集成应用。 添加处理器节点。 在左侧的“处理器”中拖拽“任务调度器”至编排区域，“任务调度器”适用于数据源之间数据调度，主要用于设置任务的集成模式、执行周期等，具体参数说明见下表。 表2 任务调度器参数配置 参数 参数说明 集成模式 选择数据集成的模式。 定时：指数据
部分执行间隔较短（如调度计划1分钟一次）的任务执行时间存在5-6分钟波动，导致单次任务执行时间会覆盖多次调度计划。建议先停止所有数据集成任务，等待规格变更完成后再重新启动任务。 如果定时任务正好在规格变更过程中调度时，部分调度日志显示时间可能比用户制定的调度时间晚2-3分钟，为正
当分页结束方式选择“记录总数”时，分页结束字段路径填写记录总数字段的路径。 是否增量迁移 选择是否只集成指定时间段内的数据。 首次调度采集是采集时间戳初始值到当前调度时间之间的数据，后续每一次调度采集的数据为上次采集成功的时间到当前时间之间的数据。 开始时间字段 仅当“是否增量迁移”选择开启时需要配置。
905(输出数据补偿结果) 906(读取任务正在在排队中（平台资源）) 907(读取任务被拒绝执行，因为上一次调度还没有结束) 908(写入任务正在在排队中（平台资源）) 909(写入任务被拒绝执行，因为上一次调度还没有结束) 911(读取任务没有被正常开启，请检查网络是否通畅，参数是否正确) 912
交通部门无法实时掌握城市停车位使用情况，难以针对停车问题制定有效的交通缓解措施。 解决方案 本章节介绍如何通过ROMA Connect对传统停车场的管理系统进行数字化改造，实现停车场车辆进出、计费、停车位状态的智能化管理。 停车场车位感应设备和进出门闸设备通过设备集成连接到ROMA Connec
Connect最佳实践一览表 最佳实践 说明 传统停车场管理系统数字化改造 介绍如何通过ROMA Connect对传统停车场的管理系统进行数字化改造，实现停车场车辆进出、计费、停车位状态的智能化管理。 企业数据以API形式开放共享 介绍如何通过ROMA Connect的服务集成，快速把数据库开放为RESTful
String 调度周期的单位，如天，小时等，只有定时任务且use_quartz_cron为false时才有该属性： MIN(分钟) HOUR(小时) DAY(天) WEEK(周) MON(月) 最小长度：3 最大长度：5 dispatch_interval Integer 调度周期，和
Connect实例上创建与原Kafka相同配置的Topic，包括Topic名称、副本数、分区数、消息老化时间，以及是否同步复制和落盘等。 方案一：先迁生产，再迁消费 方案介绍 本方案中，先将生产消息的业务迁移到ROMA Connect，原Kafka不会有新的消息生产。待原Kafka的消息全部消费完成后，再将消费消息业务迁移到ROMA
消费消息接口说明 功能介绍 消费指定队列中的消息，可同时消费多条消息。 当队列中消息较少时，单次消费返回的消息数量可能会少于指定条数，但多次消费最终可获取全部消息。当返回的消息为空数组时，表示未消费到消息。 endpoint为https://{rest_connect_addre
采集任务”。 在任务列表中找到需要启动的任务，单击“操作”栏中的“日志”可查看此任务的日志信息。日志信息主要包含运行实例编号、状态、调度开始和调度结束时间以及耗时时间。 父主题： 模型管理
“升序”或“降序”排序。 是否增量迁移 选择是否只集成指定时间段内的数据。 首次调度采集是采集时间戳初始值到当前调度时间之间的数据，后续每一次调度采集的数据是上次采集的最后一条数据的入库时间到当前调度时间之间的数据。 时区 仅当“是否增量迁移”选择开启时需要配置。 选择DB2数据源使用的时区，以便ROMA
附录：订阅的通知消息报文 以普通设备为例介绍订阅管理中MQS各报文示例。 消息属性 { "deviceIdentifier":"iottest2", // 设备标识 "eventTime":"1588843914884", // 消息时间 "gatewayIdentifier":"null"
消费确认接口说明 功能介绍 确认已经消费指定消息。 在消费者消费消息期间，消息仍然停留在队列中，但消息从被消费开始的30秒内不能被该消费组再次消费，若在这30秒内没有被消费者确认消费，则MQS认为消息未消费成功，将可以被继续消费。 endpoint为https://{rest_c
API调用认证开发（APP认证） 开发准备 APP认证工作原理 Java SDK使用说明 Go SDK使用说明 Python SDK使用说明 C# SDK使用说明 JavaScript SDK使用说明 PHP SDK使用说明 C++ SDK使用说明 C SDK使用说明 Android
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
