检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
stringify(res); } 构造器详情 public KafkaConsumer(Map configs) 构造一个Kafka消息消费者 参数:configs表示Kafka的配置信息 方法列表 返回类型 方法和说明 List<String> consume(String topic, long timeout
public SoapClient(SoapConfig soapCfg) 构造一个包含SoapConfig配置信息的SOAP请求。 参数:soapCfg表示传入SoapClient的配置信息。 方法列表 返回类型 方法和说明 APIConnectResponse execute() 用于发送SOAP请求
开发场景 场景说明 如果ROMA Connect支持的数据源类型无法接入您使用的数据源,您可以自行开发一个数据源插件,用于实现对数据源的读写。 同时,这个数据源插件以标准RESTful接口形式供ROMA Connect接入,最终实现ROMA Connect对数据源的读写。 这个数
HttpConfig() 构造一个无参数的HttpConfig 方法列表 返回类型 方法和说明 void addHeaderToSign(String headerName) 添加待签名的请求头 String getAccessKey() 获取签名的AccessKey。设置了AccessKey和Secr
一定的命名规则填写后端名称,方便您快速识别和查找。 集成应用 选择后端所属的集成应用。若没有可用的集成应用,可单击右侧的“新建集成应用”,创建一个集成应用。 后端请求方法 选择后端的请求方法,可选择“GET”、“POST”、“PUT”和“DELETE”。 后端请求路径 填写后端的
endpoint.identification.algorithm= username和password的值分别为Topic所属集成应用的Key和Secret。您可以参考查看和编辑集成应用获取Key和Secret。 ssl.truststore.location的值为1中解压得到的客
配合SoapClient使用,对SOAP请求进行配置。 构造器详情 public SoapConfig() 构造一个无参数的SoapConfig 方法列表 返回类型 方法和说明 String buildSoapMessage() 构造SOAP请求报文 String getBodyPrefix()
} } 构造器详情 public KafkaProducer(Map configs) 构造一个Kafka消息生产者 参数:configs表示Kafka的配置信息 方法列表 返回类型 方法和说明 org.apache.kafka.clients.producer.RecordMetadata
速识别和查找。 编码格式 默认“utf-8”格式。 集成应用 选择数据源所归属的集成应用。 描述 填写数据源的描述信息。 连接地址 填写RabbitMQ的连接IP地址和端口号。 用户名 填写连接RabbitMQ的用户名。 密码 填写连接RabbitMQ的用户密码。 虚拟主机 填写要连接的RabbitMQ虚拟主机名称。
redisClient.get("visit_count"); } 构造器详情 public JedisConfig() 构造一个无参数的JedisConfig 方法列表 返回类型 方法和说明 int getDatabase() 获取jedis的database,默认为0 String[] getIp()
附录:如何提高消息处理效率 消息生产和消费的可靠性必须由ROMA Connect、生产者和消费者协同工作才能保证,对使用ROMA Connect的生产者和消费者有如下的使用建议。 重视消息生产与消费的确认过程 消息生产 生产消息后,生产者需要根据ROMA Connect的返回信息
绑定域名 在开放API前,您需要为API分组绑定独立域名,用户通过独立域名访问分组内的API。 独立域名可分为内网域名和公网域名两种: 内网域名:部署在云服务平台内的业务系统,可以使用内网域名访问API。 公网域名:部署在云服务平台外的业务系统,可以使用公网域名访问API。 您也
ProductSerial 设备所属产品的产品标识。 必填,产品标识应已存在。 ParentDeviceClient 设备所属网关设备的客户端ID。 选填,网关设备应已存在。 ClientID 客户端ID。 选填。 DeviceIdentifier 设备标识。 必填,复杂度要求与页面创建相同。
响应Body参数 参数 参数类型 描述 name String 后端API名称。 支持汉字、英文、数字、中划线、下划线、点、斜杠、中英文格式下的小括号和冒号、中文格式下的顿号,且只能以英文、汉字和数字开头。 最小长度:3 最大长度:100 path String 后端API请求路径。 支持英
statement or mixed based replication forma,如下图所示。 解决方案 该问题是debezium当前版本的一个BUG,需要用户升级MySQL。 对于组合任务,可以尝试通过修改配置的方法规避,首先删除此表的配置,启动任务后会跳过这些数据,等任务执行成功后,再将表配置回来重新采集。
Connect实例的计费周期是根据您购买的时长来确定的(以GMT+8时间为准)。一个计费周期的起点是您开通或续费资源的时间(精确到秒),终点则是到期日的23:59:59。 例如,如果您在2023/10/16 15:50:04购买了一个时长为一个月的ROMA Connect实例,那么其计费周期为:2023/10/16
权限对云服务进行操作。 权限根据授权的精细程度,分为角色和策略。角色以服务为粒度,是IAM最初提供的一种根据用户的工作职能定义权限的粗粒度授权机制。策略以API接口为粒度进行权限拆分,授权更加精细,可以精确到某个操作、资源和条件,能够满足企业对权限最小化的安全管控要求。 如果您要
查询API历史版本列表 功能介绍 查询某个API的历史版本。每个API在一个环境上最多存在10个历史版本。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /
产品的设备类型,默认Default。 最小长度:0 最大长度:64 product_type 否 Integer 产品类型,0-普通产品(不支持子设备) 1-网关产品。 最小值:0 最大值:10 protocol_type 否 Integer 产品的协议类型 0-mqtt 1-CoAP 2-modbus
111或以上版本的Java Development Kit。 设备开发要求: 通过MQTT协议接入设备时,当前仅支持MQTT协议中的QoS0和QoS1。 为防止因网络不稳定或实例升级等原因导致设备连接中断,建议在设备开发过程中增加自动重连机制。如果使用ROMA Connect提供的