-
SSL证书管理 - 应用与数据集成平台 ROMA Connect
以文本方式打开待添加证书里的PEM格式证书文件(后缀名为“.pem”),将证书内容复制到“证书内容”中即可。 若证书为非pem编码格式,可参考转换证书为PEM格式进行证书格式转换。 密钥 填写pem编码格式的SSL证书密钥。 以文本方式打开待上传证书里的KEY格式或PEM格式的私钥文件(后缀名为“.pem”或“
-
Java客户端使用说明 - 应用与数据集成平台 ROMA Connect
修改配置信息 为了方便,下文分生产与消费两个配置文件介绍。如果ROMA Connect实例开启了SASL认证,在Java客户端的配置文件中必须配置涉及SASL认证的相关信息,否则无法连接。如果没有使用SASL认证,请注释掉相关配置。 生产消息配置文件(对应生产消息代码中的mqs.sdk.producer
-
CodeArts Req - 应用与数据集成平台 ROMA Connect
找到原来已下载的AK/SK文件,文件名一般为:credentials.csv。 Secret Access Key 当前账号的SK(Secret Access Key)。请参考访问密钥获取SK,如果已生成过AK/SK,找到原来已下载的AK/SK文件,文件名一般为credentials
-
接入IBM MQ数据源 - 应用与数据集成平台 ROMA Connect
套件名称。 公钥库文件 仅当“是否开启SSL认证”选择“是”时需要配置。 SSL认证过程中,客户端(ROMA Connect)使用的公钥库文件,与服务端(IBM MQ)使用的私钥相匹配。 公钥库密码 仅当“是否开启SSL认证”选择“是”时需要配置。 公钥库文件对应的密码。 以开启
-
准备Docker环境和镜像 - 应用与数据集成平台 ROMA Connect
ge_id为4中查询到的对应组件的镜像ID。 把导出的镜像文件上传到服务器中。 把镜像文件filebeat_image.tar上传到SHUBAO组件所在节点,步骤1查询到的所有SHUBAO所在的节点都要上传。 把镜像文件logstash_image.tar、elasticsearch_image
-
导入导出数据集成任务 - 应用与数据集成平台 ROMA Connect
进入实例控制台。 在左侧的导航栏选择“数据集成 FDI > 任务管理”。 在任务管理页面中单击“导入任务”按钮,界面弹出本地文件目录,选中需要导入的文件进行导入。 在“导入任务”弹窗中根据实际情况选择导入类型,可选择“全量新增”或“覆盖导入”。 父主题: 数据集成任务管理
-
Java SDK使用说明 - 应用与数据集成平台 ROMA Connect
} } doFilter函数为签名校验代码。校验流程如下:由于filter中需要读取body,为了使得body可以在后续的filter和controller中再次读取,把request包装起来传给后续的filter和controller。包装类的具体实现可见RequestWrapper
-
查看数据集成任务 - 应用与数据集成平台 ROMA Connect
包含任务的调度日志和操作日志信息。支持保留最近10000条记录。 调度日志:指任务执行的信息记录,包括计划调度时间、取数时间、数据量、各阶段耗时、数据源读取耗时、系统处理耗时和统计周期等。 操作日志:指任务的管理操作记录,包括创建、更新、删除、启动、停止等操作。 查看调度信息 登录ROMA C
-
接入RabbitMQ数据源 - 应用与数据集成平台 ROMA Connect
选择SSL认证所使用的协议,固定为“TLS”。 公钥库文件 仅当“是否开启SSL认证”选择“是”时需要配置。 SSL认证过程中,客户端(ROMA Connect)使用的公钥库文件,与服务端(RabbitMQ)使用的私钥相匹配。 公钥库密码 仅当“是否开启SSL认证”选择“是”时需要配置。 公钥库文件对应的密码。 Ra
-
自定义数据源开发示例(定时任务) - 应用与数据集成平台 ROMA Connect
getOffset() == 0 ? 1 : pagination.getOffset(); } //获取要读取的表名 String tableName = readerParams.getExtend().getString("table_name");
-
附录 - 应用与数据集成平台 ROMA Connect
附录 获取项目ID 获取账号ID 状态码 错误码 实例支持的APIC特性 数据集成参数说明 获取数据源配置文件
-
下载证书 - 应用与数据集成平台 ROMA Connect
息头中X-Subject-Token的值)。 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 - File 证书文件 状态码: 400 表4 响应Body参数 参数 参数类型 描述 error_code String 错误码 error_msg String
-
发布资产 - 应用与数据集成平台 ROMA Connect
编写资产文档,包括资产的简介、规格、典型案例和使用指导文档,然后单击“下一步”。 您可以单击右下角的“模板”,使用系统提供的默认文档模板。也可以拖动添加“文本”、“图片”和“文件”等组件自定义文档结构。 请确保资产文档信息的正确性和完整性,否则会影响资产上架的审批。 图3 资产文档 确认前面配置的资产基本信息、资产
-
使用Kibana查看日志 - 应用与数据集成平台 ROMA Connect
ite_access_log_开头的所有日志索引文件。 日志索引的名称格式为site_access_log_{es_index_name}_{current_date (YYYY-MM-dd)},在编辑logstash.conf文件时设置。 在数据视图中查看日志数据和日志统计。
-
创建前端自定义认证 - 应用与数据集成平台 ROMA Connect
其他参数请参考创建函数API进行设置。 后端创建完成后,页面自动跳转到该后端的编辑器页面。 开发函数后端的功能实现。 在编辑器的左上角单击“文件 > 新建函数后端 > 空白模板”,在弹窗中单击“确定”,然后编写用于安全认证的函数脚本,完成后单击“保存”。 用于前端自定义认证的函数脚本应满足如下条件:
-
修改数据源 - 应用与数据集成平台 ROMA Connect
最小长度:0 最大长度:256 config_file_name 否 String 用户认证文件,文件获取方式参见API参考的“附录>获取数据源配置文件”章节 将获取到的文件打包成zip文件,文件名配置在config_file_name中,内容以BASE64编码形式放到config_file_content
-
附录:spring-kafka对接限制 - 应用与数据集成平台 ROMA Connect
持。 不支持zstd压缩类型 Kafka在2.1.0版本新增了zstd压缩类型,而1.1.0版本的Kafka不支持zstd压缩类型。 配置文件: src/main/resources/application.yml 配置项: spring: kafka: producer:
-
CodeArts TestPlan - 应用与数据集成平台 ROMA Connect
找到原来已下载的AK/SK文件,文件名一般为:credentials.csv。 Secret Access Key 当前账号的SK(Secret Access Key)。请参考访问密钥获取SK,如果已生成过AK/SK,找到原来已下载的AK/SK文件,文件名一般为credentials
-
创建数据源 - 应用与数据集成平台 ROMA Connect
最小长度:0 最大长度:256 config_file_name 否 String 用户认证文件,文件获取方式参见API参考的“附录>获取数据源配置文件”章节 将获取到的文件打包成zip文件,文件名配置在config_file_name中,内容以BASE64编码形式放到config_file_content
-
企业微信 - 应用与数据集成平台 ROMA Connect
参数 说明 消息内容 markdown内容,最长不超过4096个字节,必须是utf8编码。 表27 机器人推送文件消息 参数 说明 文件ID 文件ID,可通过群机器人文件上传接口获取。 表28 机器人推送图片消息 参数 说明 图片内容Base64编码 图片内容的base64编码。