检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
自定义数据源开发示例（定时任务） 操作场景 FDI当前支持接入MySQL类型数据库，但因为MySQL是最常用的数据库类型，可以方便开发者参照理解，故本章节以MySQL类型自定义连接器为例进行开发，示例使用Java语言进行开发，Demo代码参考MysqlConnctor.rar。 前提条件
Hive目标端写入时出现数据乱码 原因分析 创建任务时，目标端存储类型选择与建表时类型不一致。 比如建表时存储类型为text（文本文件），而创建任务时目标端存储类型选择了RCFile格式。 解决方案 修改界面选择的存储类型与建表时一致即可。 父主题： 数据集成任务
终止 “终止”处理器用于结束组合应用内的流任务。 “终止”处理器一般置于流任务的末端。 “终止”处理器无需配置参数。 父主题： 处理器
nsumer配合使用，对Kafka客户端进行配置。 构造器详情 public KafkaConfig() 构造一个无参数的KafkaConfig 方法列表 返回类型 方法和说明 static KafkaConfig getConfig(String servers, String
mode) 设置redis的类型，可设置为“SINGLE”/“CLUSTER”/“MASTER_SLAVE” 输入参数 mode：类型 public void setPassPhrase(String passPhrase) 设置redis的密码 输入参数 passPhrase：密码
模型采集 > 数据源”，单击“创建数据源”，进入创建数据源页面。接着选择“本地文件”类型的数据源，然后在数据源输入框中输入数据源名称。 在页面中配置数据源的连接信息，如下表所示。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称，根据规划自定义。建议您按照一定的命名规
构造器详情 public KafkaConsumer(Map configs) 构造一个Kafka消息消费者 参数：configs表示Kafka的配置信息 方法列表 返回类型 方法和说明 List<String> consume(String topic, long timeout
设置SOAP请求参数 输入参数 name：SOAP请求参数的名称 value：SOAP请求参数的值 public void setParameters(Map<String,String> parameters) 设置SOAP请求参数 输入参数 parameters：SOAP请求参数 public
控策略，APIC会执行默认流控策略。您可以在ROMA Connect实例控制台“实例信息”页面中的“配置参数”页签下，通过修改“ratelimit_api_limits”参数来设置API的默认流控策略。 父主题： 服务集成
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 表3 请求Body参数 参数 是否必选 参数类型 描述 name 是
SoapClient(SoapConfig soapCfg) 构造一个包含SoapConfig配置信息的SOAP请求。 参数：soapCfg表示传入SoapClient的配置信息。 方法列表 返回类型 方法和说明 APIConnectResponse execute() 用于发送SOAP请求 父主题：
数据源”，单击“创建数据源”，进入创建数据源页面。接着选择“DWS”类型的数据源，创建方式选择 “创建数据源”，然后在数据源输入框中输入数据源名称。 在页面中配置数据源的连接信息，如下表所示。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称，根据规划自定义。建议您
ges 表1 参数说明 参数 类型 必选 说明 topic_name String 是 主题名称。 请求消息 请求参数 参数 类型 必选 说明 messages Array 是 消息列表，数组大小不能超过10，且不能为空数组。 表2 messages参数 参数 类型 必选 说明 content
接入MRS Hive数据源 概述 ABM支持把MRS Hive作为一种数据源类型，并用于模型采集。在使用MRS Hive类型数据源前，您需要先接入数据源。 前提条件 已为机机交互用户配置执行权限。 操作步骤 登录ROMA Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。
enumerations String 参数枚举值 min_num Integer 参数最小值 参数类型为NUMBER时有效 max_num Integer 参数最大值 参数类型为NUMBER时有效 min_size Integer 参数最小长度 参数类型为STRING时有效 max_size
物联网平台 消息接收方 边设备 参数说明 子设备添加成功后会返回响应，其中包含新增的子设备信息，二次开发需自行在本地保存新增的子设备信息，其中返回的deviceId字段将用于子设备数据上报、设备状态更新和子设备删除。 响应参数说明 字段名 必选/可选 类型 参数描述 mid 必选 Integer
一个“分支判断”节点中，如果存在多个相同的“满足当前条件时”类型的表达式，最终将执行最先创建的分支上的步骤。 一个“分支判断”节点中，只允许存在一个“不满足其他条件时”类型的分支。 配置参数 参数 说明 条件类型 包含“满足当前条件时”和“不满足其他条件时”两种条件类型。 满足当前条件时，表示传入“分支判
400 表7 响应Body参数 参数 参数类型 描述 error_code String 错误码。 最小长度：8 最大长度：36 error_msg String 错误描述。 最小长度：2 最大长度：512 状态码： 404 表8 响应Body参数 参数 参数类型 描述 error_code
计算Md5值。 方法列表 返回类型 方法和说明 static String md5(String source) 计算字符串的Md5值 方法详情 public static String md5(String source) 计算字符串的Md5值 输入参数 source：需要计算Md5的字符串
FRI 周五 7 SAT 周六 注意事项 每一个参数都使用数字，但还可以出现如下特殊字符。 *：表示匹配该域的任意值。假如在“分”使用“*”，即表示每分钟都会触发事件。 ?：只能用在“日（每月中的一天）”和“周”两个参数中。它也匹配参数的任意值，但实际不会。因为“日（每月中的一天）
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
