检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Kafka到Mysql的实时任务时,MQS中的Topic下有数据,但是FDI任务没有采集到数据。 Mysql到Mysql的定时任务,源端有类型为tinyint(1),值为2的字段,但是采集到目标端值就变成了1 目标端数据源为公网Kafka时,定时任务目标端报“The task executes
RCU分布配置 分布给不同集成能力的RCU值。 消息存储空间 实例的MQS消息存储空间信息,包括存储类型和存储空间使用率(百分比)。 MQS基本信息 实例的MQS的基本配置信息。 对应Kafka引擎类型,您可以根据实际需要修改“容量阈值策略”。 连接地址 实例的相关对接地址,包括: ROMA
I请求进行安全认证。 无认证:表示API请求不需要认证。 自定义认证 仅当“前端安全认证”选择“自定义认证”时需要配置。 选择已创建的前端类型自定义认证。 前端请求协议 选择前端API使用的请求协议,可选择“HTTP”、“HTTPS”和“HTTP&HTTPS”,传输重要或敏感数据时推荐使用HTTPS。
KafkaConsumer(Map configs) 构造一个Kafka消息消费者 参数:configs表示Kafka的配置信息 方法列表 返回类型 方法和说明 List<String> consume(String topic, long timeout, long maxItems)
instances 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见API参考的“附录 > 获取项目ID”章节。 表2 Query参数 参数 是否必选 参数类型 描述 include_internal 是 String
对Kafka客户端进行配置。 构造器详情 public KafkaConfig() 构造一个无参数的KafkaConfig 方法列表 返回类型 方法和说明 static KafkaConfig getConfig(String servers, String groupId) 获
KafkaProducer(Map configs) 构造一个Kafka消息生产者 参数:configs表示Kafka的配置信息 方法列表 返回类型 方法和说明 org.apache.kafka.clients.producer.RecordMetadata produce(String
不涉及跨域访问,此处不开启。 配置API的请求参数。为简单起见,此处不定义请求参数,直接单击“下一步”。 选择“后端服务类型”,本配置样例中选择“Mock”类型后端服务,固定返回指定响应结果。 配置API的后端配置信息。 图4 后端配置信息 表4 后端配置信息 参数 配置说明 Mock自定义返回码
说明 源端数据源 设置源端数据源,数据库类型的数据源在选择完表之后会自动显示字段信息,其他格式的数据源需要通过导入文件或者手动增加的形式来添加字段。导入的文件目前主要支持json,xml和csv格式导入。 目的端数据源 设置目的端数据源,数据库类型的数据源在选择完表之后会自动显示字段
在变量配置弹窗中单击“添加”,添加变量。 表2 配置变量 参数 说明 变量名 填写变量的名称,后续将通过变量名称进行引用。 配置类型 选择变量的数据类型,可选择“字符串”、“整数”、“长整数”、“小数”、“布尔”和“密码”。 变量值 填写变量的值。 作用域 选择变量的生效范围,是
台。 在左侧的导航栏选择“数据源管理”,单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下,选择“MRS HDFS”类型的数据源,然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称,根据规
CU数量越多,集成能力的性能规格越高。 连接器 ROMA Connect支持常见的数据源类型,如关系型数据库、大数据存储、半结构化存储、消息系统等。如果ROMA Connect支持的数据源类型无法满足您的数据集成场景,您可以自行开发一个数据源读写插件,通过标准的RESTful接口与ROMA
Connect实例一般通过公网互通,请确保ROMA Connect实例已绑定弹性IP。 接入设备 创建产品。 在“产品管理”页面单击“创建产品”,产品类型选择“普通产品”,协议类型选择“OPC UA”。 创建设备。 在“设备管理”页面单击“创建设备”,所属产品选择上一步创建的产品。 下载EdgeShell安装包。
采集任务”。在任务列表中找到需要启动的任务,单击“操作”栏中的“启动”即可启动任务。 启动:表示启动采集任务的定时任务,即按照创建采集任务时配置的开始执行时间、周期类型以及执行周期启动采集任务。 执行:表示立即执行一次此采集任务。 任务启动后,“启动”按钮会变为“停止”按钮,单击“停止”即可停止任务。 修改采集任务
构造一个包含SapRfcConfig配置信息的SapRfcClient。 参数:config表示传入SapRfcClient的配置信息。 方法列表 返回类型 方法和说明 Map<String, Object> executeFunction(String functionName, Map<String
台。 在左侧的导航栏选择“数据源管理”,单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下,选择“MRS Hive”类型的数据源,然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称,根据规
return StringUtils.toString([97,96,95,94,93,92], "UTF-8") } 方法列表 返回类型 方法和说明 static String toString(byte[] bytes, String encoding) 将字节数组转换为字符串
在左侧导航栏选择“资产中心>资产目录”。 单击资产卡片,进入资产详情页面,页面信息请参考表1。 表1 资产信息 页签 包含信息 资产介绍 资产类型、目录选择、可见范围、创建人、创建时间、资产详情。 组合应用 此页签仅组合应用资产可见。 组合应用列表及组合应用流任务详情。 API资产 此页签仅API产品资产可见。
前提条件 请确认包年/包月的实例还未到期。 在续费管理页面开通自动续费 进入“费用中心 > 续费管理”页面 自定义查询条件。例如,选择“产品类型”为“应用与数据集成平台”。 可对“手动续费项”、“自动续费项”、“到期不续费项”页签的资源设置到期转按需的操作。 可在“到期转按需项”页签查询已经设置到期转按需的资源。
台。 在左侧的导航栏选择“数据源管理”,单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下,选择“RocketMQ”类型的数据源,然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称,根据规