检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Demo包括两个文件，DeviceConnectDemo.java用于连接设备，DeviceControlDemo.java用于调用控制设备的API。 配置设备连接信息 解压Demo压缩包，在“src”目录的底层路径下找到DeviceConnectDemo.java文件。 使用Jav
最小长度：0 最大长度：256 config_file_name String 用户认证文件，文件获取方式参见API参考的“附录 > 获取数据源配置文件”章节。 将获取到的文件打包成zip文件，文件名配置在config_file_name中，内容以BASE64编码形式放到config_file_content。
统计CDC任务（组合任务）当前在处理的还未提交的最早事务对应时间距离实时的时间差。 对于MySQL类型的CDC任务，此指标表示任务正在读取的Binlog日志对应的时间与当前系统时间的差值，代表了实时读取的延迟情况。此指标的值与任务调度日志页面中显示的“读端实时监控”是一致的。 ≥0 单位：毫秒 任务 1分钟
在创建集成应用弹窗中填写集成应用的“名称”，然后单击“确认”。 接入数据源。 配置ROMA Connect接入业务系统的数据库，确保可以正常从数据库读取和写入数据。 不同类型数据源的接入配置不同，此处以Kafka作为源端数据库，MySQL作为目标端数据库为例进行说明，其他类型数据库请参考接入数据源。
连接数限制：3000 消息大小：不能超过10MB 使用SASL_SSL协议访问ROMA Connect：确保DNS具有反向解析能力，或者在hosts文件配置ROMA Connect所有节点ip和主机名映射，避免Kafka client做反向解析，阻塞连接建立。 磁盘容量申请超过业务量 *
curl_global_cleanup(); return 0; } 运行make命令编译，得到可执行文件main，执行main文件，查看结果。 父主题： API调用认证开发（APP认证）
接入SFTP数据源 接入SYBASEIQ数据源 接入HANADB数据源 接入APPCUBE数据源 接入APIC数据源 接入数据治理中心数据源 接入本地文件数据源 接入IOT数据源 接入自定义数据源 父主题： 采集技术模型
sig_params_free(¶ms); return 0; } 运行make命令编译，得到可执行文件main，执行main文件，查看结果。 父主题： API调用认证开发（APP认证）
应用，用户使用集成应用的Key和Secret进行API请求的安全认证。 创建并开放数据API 接入数据源 接入数据源，确保可以正常从数据源读取数据。 创建数据API 把数据源定义为API，并对外开放。 配置API授权（可选） 仅使用APP认证方式的API，才需要配置调用授权，把A
dbf为CDB中XStream管理员用户的表空间文件，请根据实际规划设置。 ORCLPDB1为PDB数据库的名称。 /opt/oracle/oradata/ORCLCDB/ORCLPDB1/xstream_adm_tbs.dbf为PDB中XStream管理员用户的表空间文件，请根据实际规划设置。 c#
equests”库。 pip install requests 如果pip安装requests遇到证书错误，请下载并使用Python执行此文件，升级pip，然后再执行以上命令安装。 已在IntelliJ IDEA中安装Python插件，如果未安装，请按照图1所示安装。 图1 安装Python插件
不能以斜杠（/）结尾。 文件名前缀 填写文件名前缀，与“时间格式”配合使用，用于筛选要集成的数据文件。 时间格式 选择文件名中的时间格式，与“文件名前缀”配合使用，用于筛选要集成的数据文件。 文件类型 选择从OBS数据源获取的数据文件格式，可选择“txt”，“csv”和“zip”。
pic", "*"); return consumer; } /** * 将RocketMQ读取出来的消息转换成JSON格式的字符串，实际转换需根据RocketMQ的消息内容来实现 * * @param messageExt
jar：运行的主程序。 在设备详情页的“基本信息”页签中拷贝“边缘连接配置(IPV4)”到config目录下的mqtt.properties文件中。 执行启动脚本。 Windows下执行bin/windows/start.bat。 Linux下执行bin/linux/start.sh。
值）。 最小长度：1 最大长度：100000 表3 FormData参数 参数 是否必选 参数类型 描述 file 否 File 上传产品文件(.csv格式)，参考《使用指南》：“用户指南 > 使用指南 > 设备集成指导 > 产品管理 > 导入导出产品”中的csv格式文档示例。 响应参数
在每次任务执行过程中，如果源端的某些数据符合集成条件，但因为网络抖动或数据转换异常等原因，无法顺利集成到目标端数据源，则ROMA Connect可以将这些数据以文本文件的形式存储在OBS中。 约束与限制 如果需要配置“异常数据存储”，请展开“异常数据存储”模块参照表1进行配置，如果不需要配置，请将“异常数据存储”模块折叠，否则影响任务保存。
Connect进行数据集成的流程如下图所示。 图1 业务使用流程 已创建实例和集成应用。 接入数据源。 接入源端和目标端数据源，确保可以正常从源端读取数据以及向目标端写入数据。 创建集成任务。 数据集成任务规定了源端到目标端的数据集成规则，包括两端的数据类型、数据字段的映射规则、数据集成的过滤条件等。ROMA
应用，用户使用集成应用的Key和Secret进行API请求的安全认证。 创建并开放数据API 接入数据源 接入数据源，确保可以正常从数据源读取数据。 创建数据后端 把数据源定义为后端服务，实现从数据源中读写数据。 发布数据API 发布数据后端，生成数据API，并对外开放。 绑定域名
execute(data) { var plainText = "plainText"; //加解密用的密钥硬编码到代码中有较大的安全风险，建议在配置文件中存放，本示例以在自定义后端的配置管理中配置的secretKey为例进行说明 var secretKey = "#{secretKey}";
jar：运行的主程序。 在设备详情页的“基本信息”页签中拷贝“边缘连接配置(IPV4)”到config目录下的mqtt.properties文件中。 执行启动脚本。 Windows下执行bin/windows/start.bat。 Linux下执行bin/linux/start.sh。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
