检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Kafka获取消息，并根据实际需要选择是否执行数据抽取任务。 本章节介绍任务执行完成后，如何配置消息发送，如果不需要发送消息可不配置。 前提条件 已经在对应的应用下创建Kafka和MRS Kafka数据源，数据源创建参考接入Kafka数据源和接入MRS Kafka数据源。 已创建消息集成Topic并授发布和
在“应用授权管理”弹窗中为IAM用户授权。 在“用户列表”处勾选要授权的IAM用户。 如需筛选用户，可以在“用户筛选”处，选择“用户名称”后，输入关键字搜索需要授权的用户。 在“已选择”处为已选择的IAM用户配置集成应用的管理权限。 可为每个用户单独配置权限，也可以单击“权限”右侧的“”为所有已选择用户批量配置权限。
值，则发送到该网关组件上的请求会触发断路器，其他未超过阈值的网关组件依然正常转发请求。 您可以在ROMA Connect实例控制台的“实例信息”页面，在“连接地址”下查看网关组件的IP个数，一个IP表示为一个网关组件。 最小调用次数 仅当“条件模式”选择“百分比”时需配置。 时间
connect_address string 实例连接IP地址，VPC内地址。 instance_id string 实例ID。 project_id string 项目ID。 public_ip string 实例绑定的弹性IP地址。 status string 实例的状态。 响应示例 {
当后端服务没有在设置的后端超时时间内返回时，API网关提示后端服务调用失败。 如果“后端服务地址”在ECS（Elastic Cloud Server），ECS的安全组无法被外部访问。 解决方案 在编辑API中修改后端服务地址。 在编辑API中增加后端超时时间。 确认业务的出入端口和协议都设置正确。
OBS产生的结果是数据映射的源端数据源，MySql是目的端数据源。可以通过使用Open API调用OBS连接器执行获取桶内对象列表的操作结果获得远端数据源的导入文件。也可以根据OBS连接器执行获取桶内对象列表的操作结果手动添加字段信息。 源端导入的文件内容： { "responseHeaders":
情况。 一个消费组下的消费者在连接同一个MQS时，最多允许该消费组下的500个消费者进行连接，超过数量的消费者将连接失败。如果一个消费组下有超过500个消费者，且需要连接同一个MQS，需要把消费者拆分到多个消费组下。 若ROMA Connect实例的消息集成在开启SASL_SSL
SASL配置信息 安全协议 连接目标Kafka所使用的安全协议。 PLAINTEXT：默认接入点的用户认证协议。 SASL_PLAINTEXT：SASL用户认证协议。 SASL_SSL：SSL用户认证协议。 消息收发机制 目标Kafka的消息收发机制，默认为PLAIN。 SASL用户名 仅当“安
Connect转发的后端服务请求进行安全认证。 本章节主要介绍如何创建一个后端自定义认证。您需要先创建一个函数后端作为认证函数，并在自定义认证中使用该函数后端作为认证后端。 创建用于后端认证的函数后端 登录ROMA Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。 在左侧的导航栏选择“服务集成
public int getConnectionTimeout() 获取连接超时时间 返回信息 返回连接超时时间 public int getConnectTimeout() 获取连接超时时间 返回信息 返回连接超时时间 public Object getContent() 获取HTTP请求内容
在开放API前，您需要为API分组绑定一个独立域名，供用户访问API使用。 在绑定独立域名前，您可以使用系统为API分配的默认子域名进行API调用测试，ROMA Connect对默认子域名的访问次数做了限制，每天最多可以访问1000次。 配置API授权（可选） 仅使用APP认证方
获取HTTP请求编码格式 返回信息 返回HTTP请求编码格式 public int getConnectTimeout() 获取连接超时时间 返回信息 返回连接超时时间 public Object getContent() 获取请求内容 返回信息 返回请求内容 public String
lang.IllegalArgumentException: {IP address}_{timestamp}”错误 使用MQTTBox客户端连接ROMA Connect失败
业务使用介绍 功能简介 消息集成MQS是ROMA Connect的消息集成组件，使用统一的消息接入机制，提供跨网络访问的安全、标准化消息通道。使用ROMA Connect进行消息集成，有如下优势： 支持原生Kafka特性 兼容社区版Kafka的API，具备原生Kafka的所有消息处理特性。
步骤四：验证结果 准备工作 在开始操作前，您需要提前完成以下准备工作。 已申请体验版实例或者已创建新版ROMA Connect实例。 已在本地PC上下载并安装Postman工具。 步骤一：新建组合应用 登录新版ROMA Connect控制台。 在左侧的导航栏选择“组合应用”，在页面上方单击“新建组合应用”。
数据集成开发指导 开发说明 连接器RESTful接口规范 自定义数据源开发示例（定时任务） 自定义数据源开发示例（实时任务）
ExchangeConfig exchangeConfig) 构造一个RabbitMQ客户端配置。 参数： connectionConfig表示客户端连接配置。 queueConfig表示队列配置。 exchangeConfig表示交换器配置。 父主题： 自定义后端开发（函数后端）
获取项目ID”章节。 instance_id 是 String 实例ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。
务项目来划分。在购买ROMA Connect实例时选择指定企业项目，新购云资源将按此企业项目进行成本分配。详细介绍请参见通过企业项目维度查看成本分配。 图2 为ROMA Connect实例选择企业项目 新版ROMA Connect实例暂不支持选择企业项目，企业项目默认为default。
导出数据集成任务 登录ROMA Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。 在左侧的导航栏选择“数据集成 FDI > 任务管理”。 在任务管理页面中勾选需要导出的任务，单击“导出任务”按钮，系统将自动导出所选任务到本地。 导入数据集成任务 登录ROMA
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
