检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
数据筛选 “数据筛选”组件对传入该组件的数据按照指定的表达式进行筛选,并将筛选出的结果通过节点变量传递给后续节点。通常“数据筛选”组件会作为“数据拆分”组件的后续步骤以配合使用。 配置参数 参数 说明 表达式 数据筛选的表达式。 使用表达式对数据进行筛选,并传递给后续节点。例如数
智能助手 智能助手通过NLP (Natural Language Processing) 机器学习,理解用户输入的集成业务需求,匹配系统支持的触发器、连接器和数据处理器,生成组合应用。可以对生成的组合应用进一步配置和编排,最后构建,部署上线。 操作步骤 登录新版ROMA Connect控制台。
有效期到 signature_algorithm String 签名算法 create_time String 创建时间 update_time String 更新时间 algorithm_type String 证书算法类型: RSA ECC SM2 is_has_trusted_root_ca
product_id integer 产品ID。 product_name string 产品名。 product_serial string 产品序列号。 remark string 描述信息,不能超过200个字符。 user_name string 用户名。 响应示例 { "product_id":
Connect,部分还涉及将持久化的消息文件迁移到ROMA Connect上。 在业务迁移过程中,连续性要求高的业务,需要平滑迁移,不能有长时间的中断。 迁移准备 确保消息生产与消费客户端与ROMA Connect实例的消息集成MQS连接地址网络互通。您可以在ROMA Connec
填写配置的名称,根据规划自定义。 所属集成应用 选择配置所归属的集成应用。 配置类型 选择配置的类型,可选择“模板变量”、“密码”和“证书”。 配置值 仅当“配置类型”选择“模板变量”和“密码”时可配置。 填写模板变量或密码的值。 确认配置值 仅当“配置类型”选择“密码”时可配置。 填写密码的值,需与“配置值”保持一致。
created_date_start 否 Long 创建时间起始,格式timestamp(ms),使用UTC时区。 最小值:1 最大值:99999999999999999 created_date_end 否 Long 创建时间截止,格式timestamp(ms),使用UTC时区。
填写配置的名称,根据规划自定义。 所属集成应用 选择配置所归属的集成应用。 配置类型 选择配置的类型,可选择“模板变量”、“密码”和“证书”。 配置值 仅当“配置类型”选择“模板变量”和“密码”时可配置。 填写模板变量或密码的值。 确认配置值 仅当“配置类型”选择“密码”时可配置。 填写密码的值,需与“配置值”保持一致。
该组合应用下流任务运行过程的相关记录信息。 表1 运行记录字段说明 字段 说明 开始时间 流任务的开始时间。 结束时间 流任务的结束时间。 运行ID 流任务的运行ID。 运行时间 流任务的运行时间。 状态 流任务的运行状态。 (可选)配置访问日志,实现异常监控日志的存储。 如果组
函数工作流 函数工作流连接器用于对接华为云函数工作流(FunctionGraph)服务,可以调用已创建的函数进行数据处理,后续节点可引用变量的方式引用函数处理的结果。 前提条件 使用函数工作流服务时,还需要具备项目级服务FunctionGraph Administrator角色权限。
提交确认消费的超时时间,客户端需要在该时间内提交消费确认,如果超过指定时间,没有确认消费,系统会报消息确认超时或handler无效,则默认为消费失败。取值范围:1~300s。默认值:15s time_wait Integer 否 设定队列可消费的消息为0时的读取消息等待时间。 如果在等
False:表示并行处理的分支出现错误后,整个任务会继续执行后续节点。 超时时间(ms) 并行处理过程的最长执行时间,如果超过该时间后,仍有未执行完成的分支任务,则该分支的任务将被丢弃,且最终的合并结果中不会包含该分支。 超时时间为0时,表示不设置超时时间,将等待所有分支任务执行完成。 “并行处理”节点的
等特殊字符,总长度不超过512,且满足URI规范。 支持环境变量,使用环境变量时,每个变量名的长度为3 ~ 32位的字符串,字符串由英文字母、数字、中划线、下划线组成,且只能以英文开头。 说明: 需要服从URI规范。 timeout Integer 服务集成请求后端服务的超时时间。最大超时时间可通过实例特性backe
将日期时间转换为本地日期时间。 toLocalTime(string datetime, string format) 将时间转换为本地时间。 today() 返回当天午夜的时间。 tomorrow() 返回第二天午夜的时间。 yesterday() 返回前一天午夜的时间。 编解码(2个)
ip3:port3 #发送确认参数 acks=all #键的序列化方式 key.serializer=org.apache.kafka.common.serialization.StringSerializer #值的序列化方式 value.serializer=org.apache
次数。例如“异常阈值”设置为“5”,则在连续5次检查失败时,判定服务器的状态异常。 超时时间 健康检查的响应超时时间,单位为秒,超过时间无响应则认为检查失败。 间隔时间 连续两次检查的间隔时间,单位为秒。 HTTP响应码 仅当“协议”选择“HTTP”或“HTTPS”时需要配置。
次数。例如“异常阈值”设置为“5”,则在连续5次检查失败时,判定服务器的状态异常。 超时时间 健康检查的响应超时时间,单位为秒,超过时间无响应则认为检查失败。 间隔时间 连续两次检查的间隔时间,单位为秒。 HTTP响应码 仅当“协议”选择“HTTP”或“HTTPS”时需要配置。
有效期到 signature_algorithm String 签名算法 create_time String 创建时间 update_time String 更新时间 algorithm_type String 证书算法类型: RSA ECC SM2 is_has_trusted_root_ca
有效期到 signature_algorithm String 签名算法 create_time String 创建时间 update_time String 更新时间 algorithm_type String 证书算法类型: RSA ECC SM2 is_has_trusted_root_ca
次数。例如“异常阈值”设置为“5”,则在连续5次检查失败时,判定服务器的状态异常。 超时时间 健康检查的响应超时时间,单位为秒,超过时间无响应则认为检查失败。 间隔时间 连续两次检查的间隔时间,单位为秒。 HTTP响应码 仅当“协议”选择“HTTP”或“HTTPS”时需要配置。