检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
MQS连接开发(RESTful API) Java Demo使用说明 生产消息接口说明 消费消息接口说明 消费确认接口说明 父主题: 消息集成开发指导
user_id String 用户ID(保留字段,未使用)。 最小长度:0 最大长度:64 user_name String 用户名。 最小长度:0 最大长度:64 表5 LastUpdatedUser 参数 参数类型 描述 user_id String 用户ID(保留字段,未使用)。
title”字段值作为API分组名称。在导入API前,不能手动修改API定义文件中的“info.title”字段值。 导入API 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“服务集成 APIC > API管理”,在“API列表”页签上方单击“更多
在“应用授权管理”弹窗中为IAM用户授权。 在“用户列表”处勾选要授权的IAM用户。 如需筛选用户,可以在“用户筛选”处,选择“用户名称”后,输入关键字搜索需要授权的用户。 在“已选择”处为已选择的IAM用户配置集成应用的管理权限。 可为每个用户单独配置权限,也可以单击“权限”右侧的“”为所有已选择用户批量配置权限。
title”字段值作为API分组名称。在导入API前,不能手动修改API定义文件中的“info.title”字段值。 导入API 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“服务集成 APIC > API列表”,在页面右上角单击“导入API”。
最大值:99999999999999999 dest_type 否 Integer 操作类型,枚举值:0-目标端为本ROMA实例内MQS;2-目标端为本ROMA实例内MRS KAFKA数据源;3-目标端为本ROMA实例内KAFKA数据源;6-目标端为DIS数据源;7-目标端为设备;8-目标端为规则插件。 dest_topic
日志采集 “日志采集”处理器用于自定义日志信息,并显示在当前任务的运行日志中(日志级别为Debug)。 配置参数 参数 说明 日志信息 设置日志内容,可使用常量,也可通过变量的方式引用前序步骤中的数据,具体请参考引用变量。 父主题: 处理器
user_id String 用户ID(保留字段,未使用)。 最小长度:0 最大长度:64 user_name String 用户名。 最小长度:0 最大长度:64 表6 LastUpdatedUser 参数 参数类型 描述 user_id String 用户ID(保留字段,未使用)。
缺省值:0 请求参数 表3 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 最小长度:1 最大长度:100000 响应参数 状态码:
user_id String 用户ID(保留字段,未使用)。 最小长度:0 最大长度:64 user_name String 用户名。 最小长度:0 最大长度:64 表5 LastUpdatedUser 参数 参数类型 描述 user_id String 用户ID(保留字段,未使用) 最小长度:0
监控信息查询相关API,可查询不同监控信息。 实例管理 实例相关API,可查询ROMA Connect的实例信息。 实例特性管理 实例特性配置相关API,包括特性配置、特性查询等操作。 标签管理 标签相关API,可查询标签信息。 配置管理 配置查询相关API,可查询实例的用户配置。 应用配置管理 应用
域名 请求参数 表3 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 响应参数 状态码: 200 表4 响应Body参数
A Connect实例作为调试运行环境。您可购买独立的ROMA Connect实例,也可以使用共享体验版实例。 工作流在线调试功能可能会对运行在所选实例上的其它工作流产生影响,推荐您使用独立的实例进行调试。 使用工作流在线调试功能,调试环境如果选择共享体验版实例,您可同时调试的最
Connect提供了API的可视化分析和统计能力,支持查看API的调用统计。 Site实例中不支持API分析。 操作步骤 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“服务集成 APIC > API分析”,在“调用分析”页签中可查看API的调用统计情况。
使用Filebeat+ELK实现Site协同版实例的API日志监控 方案概述 资源规划 准备Docker环境和镜像 修改Filebeat和ELK配置 部署Filebeat和ELK 配置索引生命周期策略(可选) 使用Kibana查看日志
String 实例ID。 最小长度:1 最大长度:64 task_id 是 String 任务唯一标识,任务的ID。 最小长度:1 最大长度:64 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通
最大值:1 请求参数 表3 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 最小长度:1 最大长度:100000 响应参数 状态码:
“0”,表示使用一机一密设备的deviceId接入。 “2”,表示使用一机一密设备的nodeId接入。 密码签名类型:长度1字节,当前支持2种类型。 “0”代表HMACSHA256不校验时间戳。 “1”代表HMACSHA256校验时间戳。 时间戳:为设备连接平台时的UTC时间,格式为YYYYMMDDHH,如UTC
需要配置,请将“异常数据存储”模块折叠,否则影响任务保存。 配置异常数据存储 在配置异常数据存储前,您需要提前完成OBS数据源的接入配置,具体请参见接入OBS数据源。 在创建任务页面中配置异常数据存储信息。 表1 异常数据存储信息 参数 配置说明 集成应用 选择OBS数据源所属的集成应用。
查看界面上的采集数据,如果写入数据耗时在秒级,属于正常的情况。如果写入几千条数据超过5秒,一般是性能劣化的表现。 解决方案 如果对DWS的某个表频繁访问,会导致写入性能逐渐降低,需要对DWS进行调优,例如,定时使用analyze规划表、VACUUM FULL等。 父主题: 数据集成组合任务