检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
前提条件 已经在对应的应用下创建Kafka和MRS Kafka数据源,数据源创建参考接入Kafka数据源和接入MRS Kafka数据源。 已创建消息集成Topic并授发布和订阅权限。创建Topic和授权参考消息集成指导章节。 配置任务完成后执行 在创建任务页面中配置任务完成后执行信息。
了可视化的管理界面,便于配置和监控,具有较高的可靠性和灵活性。ActiveMQ可用于构建分布式系统,支持多种编程语言和平台,提供了广泛的API支持。 创建ActiveMQ连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”,在连接器页面单击“新建连接”。 选择“ActiveMQ”连接器。
仅支持“定时”模式的目标端数据类型 API ActiveMQ ArtemisMQ DB2 DWS Kafka MySQL MongoDB Oracle PostgreSQL RabbitMQ SQL Server OBS API 任务的“集成模式”为“定时”或“实时”时,可以选择API作为目标端数据源,具体配置如下。
ExchangeConfig类说明 路径 com.roma.apic.livedata.config.v1.ExchangeConfig 说明 与RabbitMqConfig和RabbitMqProducer配合使用,对交换器进行配置。 构造器详情 public ExchangeConfig(String
了可视化的管理界面,便于配置和监控,具有较高的可靠性和灵活性。ActiveMQ可用于构建分布式系统,支持多种编程语言和平台,提供了广泛的API支持。 创建ActiveMQ连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”,在连接器页面单击“新建连接”。 选择“ActiveMQ”连接器。
batchDeleteApi 修改API Api updateApi 发布API Api publishApi 下线API Api offlineApi 批量发布或下线API Api batchPublishOrOfflineApi 切换API版本 Api switchApiVersion 根据版本下线API
MQS完全兼容Kafka开源客户端。 如果您使用其他语言,也可以从Kafka官网获取客户端,按照Kafka官网提供的连接说明,与MQS对接。 获取客户端的地址请参考Kafka官网。 父主题: MQS连接开发(开源客户端)
ConnectionConfig类说明 路径 com.roma.apic.livedata.config.v1.ConnectionConfig 说明 与RabbitMqConfig和RabbitMqProducer配合使用,对RabbitMQ客户端进行连接配置。 构造器详情 public
扩大资源配额 概述 为防止资源滥用,ROMA Connect限定了各资源的配额,对可创建资源的数量做了限制,例如实例数量、API数量、设备数量等。如果当前资源配额限制无法满足使用需要,您可以申请扩大配额。 操作步骤 登录控制台,在页面右上角,选择“资源 > 我的配额”,进入“服务配额”页面。
SoapClient类说明 路径 com.roma.apic.livedata.client.v1.SoapClient 说明 使用此类进行SOAP请求。 使用示例 importClass(com.roma.apic.livedata.client.v1.SoapClient);
roma.apic.livedata.client.v1.RabbitMqProducer); importClass(com.roma.apic.livedata.config.v1.RabbitMqConfig); importClass(com.roma.apic.livedata
DataSourceConfig类说明 路径 com.roma.apic.livedata.config.v1.DataSourceConfig 说明 配合DataSourceClient使用,对数据源进行配置。 构造器详情 public DataSourceConfig() 构
RabbitMqConfig类说明 路径 com.roma.apic.livedata.config.v1.RabbitMqConfig 说明 与ConnectionConfig,QueueConfig,ExchangeConfig和RabbitMqProducer配合使用,对RabbitMQ客户端进行配置。
不同子公司或部门在开放API时,定义的API认证方式、格式等会各不相同。某个子公司或部门要访问其他子公司或部门的开放API时,需要使用不同的认证信息,增加了子公司或部门间数字资产的共享难度。 解决方案 ROMA Connect的服务集成APIC提供了API级联的能力,通过API级联能力把企
KafkaConfig类说明 路径 com.roma.apic.livedata.config.v1.KafkaConfig extends java.util.Properties 说明 与KafkaProducer或KafkaConsumer配合使用,对Kafka客户端进行配置。
KafkaConsumer类说明 路径 com.roma.apic.livedata.client.v1.KafkaConsumer 说明 消费Kafka消息。 使用示例 importClass(com.roma.apic.livedata.client.v1.KafkaConsumer);
资产导入后重新为对应数据源配置连接信息。 服务集成 未发布RELEASE环境的API 未发布RELEASE环境的API包括未发布的API和发布在非RELEASE环境的API,为非资产数据。 资产导入后根据需要重新创建和发布API。 API的环境类信息 API的环境类信息包括独立域名、环境变量、负载通道的云服务器信息、非默认的环境,为非资产数据。
场车辆进出、计费、停车位状态的智能化管理。 企业数据以API形式开放共享 介绍如何通过ROMA Connect的服务集成,快速把数据库开放为RESTful API,不同业务系统间的数据以API方式互相开放访问,同时在开放API时可选择多种安全认证方式,实现跨网络跨地域应用系统数据间的安全访问。
SapRfcConfig类说明 路径 com.roma.apic.livedata.config.v1.SapRfcConfig extends java.util.Properties 说明 与SapRfcClient配合使用,对sap客户端进行配置。 方法列表 返回类型 方法和说明
最大延迟毫秒数 统计测量api接口最大响应延时时间。 ≥0 单位:毫秒 实例 1分钟 req_count 接口调用次数 统计测量api接口调用次数。 ≥0 单个API 1分钟 req_count_2xx 2xx调用次数 统计测量api接口调用2xx的次数。 ≥0 单个API 1分钟 req_count_4xx