检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置Oracle CDC(XStream) 概述 CDC(Change Data Capture),即数据变更抓取,通过为源端数据源开启CDC,ROMA Connect可实现数据源的实时数据同步以及数据表的物理删除同步。 ROMA Connect支持Oracle的XStream和LogMiner
配置Oracle CDC(LogMiner) 概述 CDC(Change Data Capture),即数据变更抓取,通过为源端数据源开启CDC,ROMA Connect可实现数据源的实时数据同步以及数据表的物理删除同步。 ROMA Connect支持Oracle的XStream和
批量删除API 功能介绍 批量删除指定的多个API,或指定分组下的所有API。 URI PUT /v1/{project_id}/apic/instances/{instance_id}/apis 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
解除API与流控策略的绑定关系 功能介绍 解除API与流控策略的绑定关系。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI DELETE /v2/{project_id
查询VPC通道后端云服务组列表 功能介绍 查询VPC通道后端云服务组列表 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/apic
APP认证工作原理 APP认证流程 构造规范请求。 将待发送的请求内容按照与APIC后台约定的规则组装,确保客户端签名、APIC后台认证时使用的请求内容一致。 使用规范请求和其他信息创建待签字符串。 使用AK/SK和待签字符串计算签名。 将生成的签名信息作为请求消息头添加到HTTP
KafkaConsumer类说明 路径 com.roma.apic.livedata.client.v1.KafkaConsumer 说明 消费Kafka消息。 使用示例 importClass(com.roma.apic.livedata.client.v1.KafkaConsumer
XmlUtils类说明 路径 com.roma.apic.livedata.common.v1.XmlUtils 说明 提供Xml转换功能。 使用示例 importClass(com.roma.apic.livedata.common.v1.XmlUtils); function
消费确认接口说明 功能介绍 确认已经消费指定消息。 在消费者消费消息期间,消息仍然停留在队列中,但消息从被消费开始的30秒内不能被该消费组再次消费,若在这30秒内没有被消费者确认消费,则MQS认为消息未消费成功,将可以被继续消费。 endpoint为https://{rest_connect_address
附录:自定义后端的Swagger扩展定义 概述 ROMA Connect在Swagger原有定义的基础上,定义了特有的API定义项,即扩展定义,如认证方式、函数脚本定义等。本章节主要介绍自定义后端使用的扩展定义。 1:x-livedata-auth-type 含义:基于Swagger
KafkaConfig类说明 路径 com.roma.apic.livedata.config.v1.KafkaConfig extends java.util.Properties 说明 与KafkaProducer或KafkaConsumer配合使用,对Kafka客户端进行配置
SoapClient类说明 路径 com.roma.apic.livedata.client.v1.SoapClient 说明 使用此类进行SOAP请求。 使用示例 importClass(com.roma.apic.livedata.client.v1.SoapClient);
QueueConfig类说明 路径 com.roma.apic.livedata.config.v1.QueueConfig 说明 与RabbitMqConfig和RabbitMqProducer配合使用,对队列进行配置。 构造器详情 public QueueConfig(String
存储过程调用 当前数据API不支持直接创建存储过程,但是可以执行MySQL、Oracle、PostgreSQL这三种数据源的存储过程,以Oracle数据库为例说明。 数据源说明 假设数据库里面有一张表,表结构如下建表语句所示: create table sp_test(id number
Java Demo使用说明 操作场景 除了前面章节介绍的使用原生Kafka客户端,MQS实例还可以通过HTTP RESTful方式访问,包括向指定Topic发送消息、消费消息以及确认消费。 这种方式主要用于适配原有业务系统架构,方便统一使用HTTP协议接入。 入门版规格实例不支持RESTful
生产消息接口说明 功能介绍 向指定队列发送消息,可同时发送多条消息。 每次最多发送10条。 每次发送的消息总负载不超过2MB。 endpoint为https://{rest_connect_address}:9292,通过指定实例接口查询rest_connect_address的IP
为什么规则引擎的数据目的端未收到设备发送的消息? 数据目的端未收到设备发送的消息主要有以下原因: 可能是您的安全组没有添加正确的入方向规则。 请您进入“实例信息”界面,找到您的安全组。单击安全组名称进入安全组详情页面,然后根据表1添加相应的入方向规则。 表1 安全组参数 参数 端口
修改Filebeat和ELK配置 修改Filebeat配置 Filebeat目录和文件结构如下所示: |_ filebeat |_ log |_ docker-compose.yml |_ filebeat.yml 登录SHUBAO组件所在节点,切换root用户,执行以下命令创建
部署Filebeat和ELK 部署Filebeat 登录SHUBAO组件所在节点,切换root用户。 执行以下命令对filebeat.yml文件进行授权。 cd /filebeat sudo chown root filebeat.yml 执行以下命令启动Filebeat。 docker-compose
查看ACL策略未绑定的API列表 功能介绍 查看ACL策略未绑定的API列表,需要API已发布 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v2/{project_id