云服务器内容精选
-
操作步骤 进入购买ROMA Connect实例页面。 在购买ROMA Connect实例页面中配置实例的基础配置信息，完成后单击“下一步”。 表1 基础配置信息 参数 说明 区域 选择实例所在的区域，不同区域的实例之间内网互不相通，请选择您的业务就近区域购买实例，以减少网络时延，提高访问速度。 可用区 选择实例所在的可用区，不同可用区之间物理隔离，但内网互通。 如果您需要提高ROMA Connect运行的可靠性，建议您将实例创建在不同的可用区内。 如果您需要较低的网络时延，建议您将实例创建在相同的可用区内。 CPU架构 根据当前环境所支持的CPU架构，可选择项有所不同，选择“x86计算”。 实例名称 填写实例的名称，根据规划自定义。 描述 填写实例的描述信息。 RCU分配 为实例的集成能力分配RCU，仅分配到RCU的集成能力可以使用。 RCU（ROMA Compute Unit）为ROMA计算单元，可分配到不同的集成能力上。集成能力分配到的RCU越多，其性能规格越高。每RCU对应的集成能力规格请参见产品规格差异。 可根据系统推荐的场景设置各集成能力的RCU配额，或者自定义各集成能力的RCU值，总RCU值不可为0。 部分集成能力存在依赖关系： 使用组合应用(流运行)或服务集成(数据API/函数API)时，需要同时开启服务集成(API管理)。 使用设备集成时，需要同时开启消息集成。 在页面配置实例的高级配置信息，完成后单击“下一步”。 表2 高级配置信息 参数 说明 网络配置 虚拟私有云 选择实例所关联的VPC和子网，VPC和子网须在准备资源中提前创建。 入公网访问 是否开启公网访问ROMA Connect，请根据您的业务需要选择。 入公网带宽 仅当“入公网访问”开启时需要配置。 选择需要开启的入公网带宽大小。 消息集成配置（仅当“RCU分配”中为消息集成分配了RCU时可配置） 引擎版本号 选择消息集成的Kafka服务端版本号，当前支持2.7版本。 消息集成(MQS)容量阈值策略 实例中MQS消息存储达到容量阈值时（存储空间的95%）的处理策略，请根据您的业务需要选择。 生产受限：拒绝消息生产请求，直到有消息到达老化时间被删除，腾出存储空间后（剩余存储空间大于5%），才能接收新的消息生产请求。此策略适用于消息消费处理较慢，或者对存量消息需要反复消费，不能提前删除的场景。 自动删除：自动删除最老的消息（消息总量的10%），腾出存储空间，以接收新的消息生产请求，消息生产业务不受影响。此策略适用于消息消费处理较快，不存在长时间未处理消息的场景。 数据加密 传输 SASL_SSL 选择是否开启消息传输的SASL认证和SSL加密，建议您开启SASL认证和SSL加密，提高数据传输的安全性。 数据加密传输 SASL_SSL一旦开启后将无法修改，请根据实际业务需要选择是否启用。 VPC内网明文访问 仅当“数据加密传输 SASL_SSL”开启时可配置。 选择VPC内部是否使用明文访问。 如果开启了VPC内网明文访问，则VPC内无需使用SASL方式连接消息集成的Topic，即连接Topic时无需使用证书。 在配置确认界面勾选同意协议的选项，然后单击“购买实例”，实例开始创建。 实例创建大概需要15-25分钟，请耐心等待。实例创建成功后，在控制台的“资源管理”页面可看到该实例的状态为“运行中”。 如果创建实例失败，可删除创建失败的实例，然后重新创建实例。如果重新创建仍然失败，请联系技术支持。
-
操作步骤 登录新版ROMA Connect控制台。 在左侧导航栏选择“资源管理”，在资源管理页面单击新版的容器实例，进入实例控制台。 在实例控制台的“实例信息”页面中，选择“基本信息”页签，可查看和编辑实例的基本信息。 表1 ROMA Connect基本信息 内容 内容说明 ROMA Connect实例信息 实例的基本信息，包括实例名称、实例ID、描述、可用区、创建时间。 您可以根据实际需要修改“实例名称”、“描述”等。 您可以单击“实例ID”右侧的“”复制实例ID信息。 虚拟私有云 实例所关联的VPC，您可以单击VPC名称跳转查看VPC的具体配置信息。 子网 实例所关联的子网，您可以单击子网名称跳转查看子网的具体配置信息。 安全组 实例所关联的安全组，您可以单击安全组名称跳转查看安全组的具体配置信息，也可以单击“更改”按钮，绑定新的安全组。 路由 配置私有网段。ROMA Connect实例创建完成后，默认能够与创建时指定的VPC子网网段进行互通，若有额外的私有网段需要与实例互通，可通过该配置项进行路由配置。 付费信息 实例的计费模式。 RCU分布配置 分布给不同集成能力的RCU值。 消息存储空间 实例的MQS消息存储空间信息，包括存储类型和存储空间使用率（百分比）。 MQS基本信息 实例的MQS的基本配置信息。 对应Kafka引擎类型，您可以根据实际需要修改“容量阈值策略”。 连接地址 实例的相关对接地址，包括： ROMA Connect连接地址 设备集成LINK连接地址 服务集成APIC连接地址 服务集成 APIC内网连接地址（自定义后端组件和网关组件） 消息集成 MQS内网连接地址 消息集成 MQS公网连接地址（仅开启公网访问时展示） 您可以单击连接地址右侧的“”复制连接地址信息。 公网访问入口 若实例未开启公网入口，您可以单击右侧“”开启公网入口。 若实例已开启公网入口，您可以单击地址右侧的“ ”复制地址信息。 若实例已开启公网入口，您可以单击公网带宽右侧的“ ”修改公网入口带宽大小。 若实例已开启公网入口，您可以单击右侧的“ ”关闭公网入口。 须知： 弹性IP地址为随机分配，开启后关闭再开启不保证IP地址分配的前后一致性。 公网IP访问控制（白名单） 仅当“公网访问入口”开启时可配置。 公网IP访问控制采用白名单模式，在开启的情况下仅白名单内的IP地址可以访问，未开启则默认全放通。 单击右侧更改进入编辑模式，您可以添加或删除允许放通的IP地址。 私网IP访问控制（白名单） 私网IP访问控制采用白名单模式，在开启的情况下仅白名单内的IP地址可以访问，未开启则默认全放通。 单击右侧更改进入编辑模式，您可以添加或删除允许放通的IP地址。
-
调试步骤 登录新版ROMA Connect控制台。 在左侧导航栏选择“组合应用”，在组合应用页面单击需要调试的组合应用。 单击右上角的“编辑”进入组合应用设计页面。 单击页面上方“调试”按钮，进入调试模式。 图1 设计页面 选择调试环境。选择“区域”、“项目”和“实例”，作为在线调试使用的环境。 图2 配置调试环境 配置触发器节点。根据触发器节点类型，配置对应的触发参数，如Open API节点您可能需要配置API请求参数和请求Body等。 图3 配置Open API节点参数 单击“保存”，开启工作流调试。 执行调试操作，对工作流进行调试。 图4 调试工作流 添加断点：单击工作流中的节点，即可添加断点，工作流在调试过程中可能会停在当前断点。再次单击该节点，可移除断点。 触发器节点、并行处理节点和分支判断节点等不可添加断点。 调试运行：单击“调试运行”，工作流开始执行调试。如果工作流中存在断点，工作流会停留在该断点，并展示进入当前断点的数据，包括“属性”和“载荷”数据；如果工作流中不存在断点，工作流会自动运行至结束，或者在运行出错的节点停止，并展示错误信息。 单步运行：当工作流处于调试状态，停留在某一节点时，单击“单步运行”，工作流可自动运行至下一个节点。 运行到下一断点：当工作流处于调试状态，停留在某一节点时，单击“运行到下一断点”，工作流可自动运行至下一个断点。如果后续不存在断点，工作流会自动运行至结束，或者在运行出错的节点停止，并展示错误信息。 运行到结束：当工作流处于调试状态，停留在某一节点时，单击“运行到结束”，工作流会自动运行至结束，或者在运行出错的节点停止，并展示错误信息。 停止运行：当工作流处于调试状态，单击“停止运行”，工作流会终止本次调试过程。 调试完成后，单击页面右上方“退出调试”，退出调试模式，返回组合应用设计页面。
-
前置条件和约束 使用工作流在线调试功能，您需要具备ROMA Connect实例作为调试运行环境。您可购买独立的ROMA Connect实例，也可以使用共享体验版实例。 工作流在线调试功能可能会对运行在所选实例上的其它工作流产生影响，推荐您使用独立的实例进行调试。 使用工作流在线调试功能，调试环境如果选择共享体验版实例，您可同时调试的最大工作流数量为1条；如果选择购买独立的ROMA Connect实例，可同时调试的最大工作流数量为5条。 使用工作流在线调试功能，工作流的触发器节点不会真实运行，如Open API节点不会发布为API，您需要手动配置触发器节点进行触发。 使用工作流在线调试功能，在单个节点的最大停留时间为60s，超时后会自动向后运行。
-
配置参数 参数 说明 输出格式 合并结果的格式，当前仅支持“Json”，表示合并结果以JSON字符串的格式输出。 可通过如下两种方法获取某一分支的结果： 后续节点为“脚本处理”时，使用JSON.parse('${body}')方式将合并结果转换为JSON对象，然后通过分支名称获取分支的结果。如： var result=JSON.parse('${body}'); var branch_result=result.分支名称 或者 var branch_result=result['分支名称'] 后续节点为“变量赋值”、“分支判断”和“数据转换”时，使用“$.分支名”获取该分支的执行结果。 失败时停止 并行处理出现错误时的是否停止。 True：表示任一并行处理的分支出现错误时，整个任务便停止，并返回错误信息。 False：表示并行处理的分支出现错误后，整个任务会继续执行后续节点。 超时时间(ms) 并行处理过程的最长执行时间，如果超过该时间后，仍有未执行完成的分支任务，则该分支的任务将被丢弃，且最终的合并结果中不会包含该分支。 超时时间为0时，表示不设置超时时间，将等待所有分支任务执行完成。 “并行处理”节点的分支名称，需在后续相邻节点的连线上配置。
-
创建PostgreSQL连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”，在连接器页面单击“新建连接”。 选择“PostgreSQL”连接器。 在弹窗中配置连接器信息，完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 区域 选择区域。 项目 选择项目。 实例 选择实例，用于后续验证连通性。 连接与安全 选择数据库的连接模式。 默认：由系统根据用户配置自动拼接数据源连接字符串。 专业：由用户自己输入数据源连接字符串。 主机IP地址 仅当“连接与安全”选择“默认”时需要配置。 填写数据库的连接IP地址。 端口 仅当“连接与安全”选择“默认”时需要配置。 填写数据库的连接端口号。 数据库名 仅当“连接与安全”选择“默认”时需要配置。 填写要连接的数据库名。 连接字符串 仅当“连接与安全”选择“专业”时需要配置。 填写PostgreSQL数据库的JDBC格式连接串，例如：jdbc:postgresql://{hostname}:{port}/{dbname}。 用户名 连接数据库的用户名。 密码 连接数据库的用户密码。 描述 填写连接器的描述信息，用于识别不同的连接器。
-
配置参数 参数 说明 语言 选择编写脚本使用的编程语言，当前只支持ES5版本的JavaScript语言。 内容 编写脚本内容。 可通过变量的形式引用前序步骤中的数据，请参考引用变量。 当需要解析JSON格式的内容数据时，可通过“JSON.parse('${body}')”的方式将内容数据转换为JSON对象，然后进行数据解析。 脚本处理组件可以生成一个输出结果并传给后续步骤，用户需要在脚本的末尾指定要输出的变量名称，例如： function getUser(){ return {"id": ${property.id},"name":"${property.name}"}; } var user=getUser(); user; 说明： 如果需要编写函数或者逻辑代码块，需使用“{”和“}”围绕代码块。
-
创建Oracle连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”，在连接器页面单击“新建连接”。 选择“Oracle”连接器。 在弹窗中配置连接器信息，完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 区域 选择区域。 项目 选择项目。 实例 选择实例，用于后续验证连通性。 连接与安全 选择数据库的连接模式。 默认：由系统根据用户配置自动拼接数据源连接字符串。 专业：由用户自己输入数据源连接字符串。 主机IP地址 仅当“连接与安全”选择“默认”时需要配置。 填写数据库的连接IP地址。 端口 仅当“连接与安全”选择“默认”时需要配置。 填写数据库的连接端口号。 数据库名 仅当“连接与安全”选择“默认”时需要配置。 填写要连接的数据库名。 编码格式 仅当“连接与安全”选择“默认”时需要配置。 填写数据库的编码格式。 超时时间 仅当“连接与安全”选择“默认”时需要配置。 填写连接数据库的超时时间。 连接字符串 仅当“连接与安全”选择“专业”时需要配置。 填写Oracle数据库的JDBC格式连接串，例如：jdbc:oracle:thin:@{hostname}:{port}:{dbname}。 用户名 连接数据库的用户名。 密码 连接数据库的用户密码。 描述 填写连接器的描述信息，用于识别不同的连接器。
-
创建HTTP请求连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”，在连接器页面单击“新建连接”。 选择“HTTP请求”连接器。 在弹窗中配置连接器信息，完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 基本地址 要调用API的请求地址。 安全认证 要调用API所使用的认证方式。 APP认证：使用API所授权集成应用的Key和Secret进行API请求的安全认证。 无认证：表示API请求不需要认证。 APP Key（APP认证） 仅当“安全认证”选择“APP认证”时需要配置。 API所授权集成应用的Key。 APP Secret（APP认证） 仅当“安全认证”选择“APP认证”时需要配置。 API所授权集成应用的Secret。 描述 填写连接器的描述信息，用于识别不同的连接器。
-
目的端-数据格式为 CS V样例 是否跳过标题：CSV文件的表头，数值 true/false：输出数据是/否含有表头。 分隔符：文件中每列数据通过单元格进行分隔，单元格可以为“制表符”、“空格”、“逗号”、“分号”。 场景1：目的端数据源选择数据格式“CSV”，是否跳过标题：true，字段分隔符：逗号 。 导入文件时，当是否跳过标题选择“true”，默认解析csv第一行为字段名。 源端MySQL数据库表 demo.statistics 中的数据： id city uuid1 suzhou uuid2 shanghai 数据映射输出数据为： ManufacturerId, ProductName uuid1, suzhou uuid2, shanghai 场景2：目的端数据源选择数据格式“CSV”，是否跳过标题：false，字段分隔符：逗号。 导入文件时，当是否跳过标题选择“false”，不使用导入文件的头字段，系统默认设置字段filedN。 源端MySQL数据库表 demo.statistics 中的数据： id city uuid1 suzhou uuid2 shanghai 数据映射输出数据为： uuid1, suzhou uuid2, shanghai
-
源端-数据格式为JSON样例 当源端数据源的类型为“JSON”时，在使用数据映射时选择数据格式“JSON”，将源端数据源的输出作为源端数据源页签中“导入文件”的输入，根据文件的编码格式选择导入文件编码，可选项有GB2312、UTF-8和ASCII。此时源端数据源页签中会根据导入的文件内容自动生成相应的字段。 目的端数据格式选择“MySQL”，在选择表名后，目的端数据源页签会自动生成数据库表中的字段。 以下面的组合应用为例，该组合应用的主要功能是调用Open API获取OBS指定桶的对象列表，并将结果中的桶名称和对象名称通过数据映射，映射到MySql指定表中的相关字段，然后使用MySql添加记录的操作将桶名和对象名存储到MySql中。其中， 对象存储服务 OBS产生的结果是数据映射的源端数据源，MySql是目的端数据源。可以通过使用Open API调用OBS连接器执行获取桶内对象列表的操作结果获得远端数据源的导入文件。也可以根据OBS连接器执行获取桶内对象列表的操作结果手动添加字段信息。 源端导入的文件内容： { "responseHeaders": { "bucket-location": "cn-north-7", "connection": "keep-alive", "content-length": "504", "content-type": "application/xml", "date": "2024-04-24T07:07:43.000+00:00", "id-2": "32AAAQAAEAABAAAQAAEAABAAAQAAEAA BCS bOSbK ncLEgZnxffa8vFPuDgVIt7n9", "request-id": "0000018F0EEE84734012ACF15A46395E", "server": "OBS" }, "originalHeaders": { "connection": "keep-alive", "content-length": "504", "content-type": "application/xml", "date": "Wed, 24 Apr 2024 07:07:43 GMT", "server": "OBS", "x-obs-bucket-location": "cn-north-7", "x-obs-id-2": "32AAAQAAEAABAAAQAAEAABAAAQAAEAABCSbOSbK+ncLEgZnxffa8vFPuDgVIt7n9", "x-obs-request-id": "0000018F0EEE84734012ACF15A46395E" }, "statusCode": 200, "objectSummaries": [ { "bucketName": "test0223", "objectKey": "test0424.txt", "owner": { "displayName": null, "id": "0ab78f256080d2890feac0086234d7c0" }, "metadata": { "responseHeaders": {}, "originalHeaders": {}, "statusCode": 0, "lastModified": "2024-04-24T06:51:46.566+00:00", "contentLength": 19, "contentType": null, "contentEncoding": null, "contentDisposition": null, "cacheControl": null, "contentLanguage": null, "expires": null, "etag": "\"0b26e313ed4a7ca6904b0e9369e5b957\"", "contentMd5": null, "crc64": null, "storageClass": "STANDARD", "webSiteRedirectLocation": null, "nextPosition": -1, "appendable": false, "objectStorageClass": "STANDARD", "allMetadata": {}, "metadata": {}, "requestId": "" }, "objectContent": null } ], "commonPrefixes": [], "extendCommonPrefixes": [], "bucketName": "test0223", "truncated": false, "prefix": "", "marker": "", "maxKeys": 1000, "delimiter": null, "nextMarker": null, "location": "cn-north-7", "extenedCommonPrefixes": [], "objects": [ { "bucketName": "test0223", "objectKey": "test0424.txt", "owner": { "displayName": null, "id": "0ab78f256080d2890feac0086234d7c0" }, "metadata": { "responseHeaders": {}, "originalHeaders": {}, "statusCode": 0, "lastModified": "2024-04-24T06:51:46.566+00:00", "contentLength": 19, "contentType": null, "contentEncoding": null, "contentDisposition": null, "cacheControl": null, "contentLanguage": null, "expires": null, "etag": "\"0b26e313ed4a7ca6904b0e9369e5b957\"", "contentMd5": null, "crc64": null, "storageClass": "STANDARD", "webSiteRedirectLocation": null, "nextPosition": -1, "appendable": false, "objectStorageClass": "STANDARD", "allMetadata": {}, "metadata": {}, "requestId": "" }, "objectContent": null } ], "requestId": "0000018F0EEE84734012ACF15A46395E" } 数据映射输出结果为：
-
配置参数 参数 说明 源端数据源 设置源端数据源，数据库类型的数据源在选择完表之后会自动显示字段信息，其他格式的数据源需要通过导入文件或者手动增加的形式来添加字段。导入的文件目前主要支持json，xml和csv格式导入。 目的端数据源 设置目的端数据源，数据库类型的数据源在选择完表之后会自动显示字段信息，其他格式的数据源需要通过导入文件或者手动增加的形式来添加字段。导入的文件目前主要支持json，xml和csv格式导入。 如果后续节点想要引用“数据映射”处理器的输出数据，可通过${节点id|payload.xxx}的形式来引用。节点id可通过单击“数据映射”处理器获取到。
-
创建MySQL连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”，在连接器页面单击“新建连接”。 选择“MySql”连接器。 在弹窗中配置连接器信息，完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 区域 选择区域。 项目 选择项目。 实例 选择实例，用于后续验证连通性。 连接与安全 选择数据库的连接模式。当前支持“默认”模式，由系统根据用户配置自动拼接数据源连接字符串。 主机IP地址 填写数据库的连接IP地址。 端口 填写数据库的连接端口号。 数据库名 填写要连接的数据库名。 用户名 连接数据库的用户名。 密码 连接数据库的用户密码。 描述 填写连接器的描述信息，用于识别不同的连接器。
-
创建MySQL连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”，在连接器页面单击“新建连接”。 选择“MySql”连接器。 在弹窗中配置连接器信息，完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 区域 选择区域。 项目 选择项目。 实例 选择实例，用于后续验证连通性。 连接与安全 选择数据库的连接模式。当前支持“默认”模式，由系统根据用户配置自动拼接数据源连接字符串。 主机IP地址 填写数据库的连接IP地址。 端口 填写数据库的连接端口号。 数据库名 填写要连接的数据库名。 用户名 连接数据库的用户名。 密码 连接数据库的用户密码。 描述 填写连接器的描述信息，用于识别不同的连接器。
-
配置参数 表1 获取记录 参数 说明 表名 填写要查询数据的数据表名。 字段名 填写要查询数据的字段名，多个字段以英文逗号（,）分隔。 WHERE条件 填写要查询数据的条件。 Order by字段 填写返回结果的排序字段。 Limit条数 填写返回结果的每页数据条数。 Offset偏移量 填写分页查询的偏移量。 表2 获取增量记录 参数 说明 表名 填写要查询数据的数据表名。 字段名 填写要查询数据的字段名，多个字段以英文逗号（,）分隔。 WHERE条件 填写要查询数据的条件。 Order by字段 填写返回结果的排序字段。 增量获取时区 增量数据获取开始时区。 增量获取时间戳字段 增量数据获取的时间戳字段。 增量获取时间戳初始值 增量数据获取的时间戳初始值。 重置增量获取时间初始值 选择是否开启重置增量获取时间初始值。 增量获取时间补偿(毫秒） 增量获取时间补偿。 表3 添加记录 参数 说明 表名 填写要插入数据的数据表名。 插入数据 填写插入操作中目标字段的值。 表4 更新记录 参数 说明 表名 填写要更新数据的数据表名。 更新数据 填写更新操作中目标字段的值。 WHERE条件 填写要更新数据的条件。 表5 同步记录 参数 说明 表名 填写要同步数据的数据表名。 清空表 每次同步数据，是否先清空表。 表6 删除记录 参数 说明 表名 填写要删除数据的数据表名。 WHERE条件 填写要删除数据的条件。 表7 自定义SQL 参数 说明 执行语句 填写操作数据库的原生SQL语句。 执行语句内容会明文展示所输入信息，请防止信息泄露。 请谨慎使用drop、truncate等非查询类语句。
更多精彩内容
CDN加速
GaussDB
文字转换成语音
免费的服务器
如何创建网站
域名网站购买
私有云桌面
云主机哪个好
域名怎么备案
手机云电脑
SSL证书申请
云点播服务器
免费OCR是什么
电脑云桌面
域名备案怎么弄
语音转文字
文字图片识别
云桌面是什么
网址安全检测
网站建设搭建
国外CDN加速
SSL免费证书申请
短信批量发送
图片OCR识别
云数据库MySQL
个人域名购买
录音转文字
扫描图片识别文字
OCR图片识别
行驶证识别
虚拟电话号码
电话呼叫中心软件
怎么制作一个网站
Email注册网站
华为VNC
图像文字识别
企业网站制作
个人网站搭建
华为云计算
免费租用云托管
云桌面云服务器
ocr文字识别免费版
HTTPS证书申请
图片文字识别转换
国外域名注册商
使用免费虚拟主机
云电脑主机多少钱
鲲鹏云手机
短信验证码平台
OCR图片文字识别
SSL证书是什么
申请企业邮箱步骤
免费的企业用邮箱
云免流搭建教程
域名价格
