对接大数据组件 支持的大数据组件简介 Hadoop对接OBS Hive对接OBS Spark对接OBS Presto对接OBS Flume对接OBS DataX对接OBS Druid对接OBS Flink对接OBS Logstash对接OBS 父主题： 大数据场景下使用OBS实现存算分离

查看更多 →

对接大数据平台 支持的大数据平台简介 华为云 MRS 对接OBS Cloudera CDH对接OBS Hortonworks HDP对接OBS 父主题： 大数据场景下使用OBS实现存算分离

查看更多 →

Json组件使用说明 该组件为Agent Lite提供给开发者的工具组件，如果开发者无法进行Json格式的编码和解码，则可以使用该组件进行编码和解码。主要用于上报数据组装与下发命令解析。 1. Json编码 使用Json组件进行编码的流程。 创建Json编码对象。 1 HW_JSONOBJ

查看更多 →

拆分算法使用说明 MOD_HASH算法 MOD_HASH_CI算法 RIGHT_SHIFT算法 MM按月份哈希 DD按日期哈希 WEEK按星期哈希 MMDD按月日哈希 YYYYMM按年月哈希 YYYYDD按年日哈希 YYYYWEEK按年周哈希 HASH算法 Range算法 父主题：

查看更多 →

告警管理使用说明 告警是指AOM自身或外部服务在异常情况或在可能导致异常情况下上报的信息，并且您需采取相应措施清除故障，否则会由于AOM自身或外部服务的功能异常而引起业务的异常。 告警管理使用前提条件：已在主机安装ICagent，详情请参考安装ICAgent，安装之后使用流程请参见图1。

查看更多 →

告警管理使用说明 告警是指AOM自身或外部服务在异常情况、可能导致异常情况下上报的信息，并且您需采取相应措施清除故障，否则会由于AOM自身或外部服务的功能异常而引起业务的异常。 告警管理使用前提条件：已在主机安装UniAgent，详情请参考“安装UniAgent”，安装之后使用流程请参见图1。

查看更多 →

Java Demo使用说明 本文以Java语言为例，介绍应用通过MQ TTS 协议接入平台，接收服务端订阅消息的示例。 前提条件 已安装IntelliJ IDEA开发工具。若未安装请参考安装IntelliJ IDEA。 安装IntelliJ IDEA 访问IntelliJ IDEA官

查看更多 →

释放之前的connection rc = self.__connect() # rc为0表示建链成功，其它表示连接不成功 if rc != 0: print("connect with

查看更多 →

参数前缀。比如说：禁止订阅/test/v1，则该参数填写 topic:/test/v1。 操作 值为发布或订阅。发布代表MQTT设备端Publish请求，订阅代表MQTT设备端Subscribe请求。 权限 值为允许或拒绝。用于允许或拒绝某topic的发布或订阅。 绑定策略目标。

查看更多 →

其中“prefix”是安装目录，“openssldir”是配置文件目录，“shared”作用是生成动态链接库（即.so库） 。 如果编译有问题，配置命令加上no-asm（表示不使用汇编代码） ./config no-asm shared --prefix=/home/test/openssl --openssl

查看更多 →

Hive同步数据报错SemanticException 问题 Hive同步数据时报错： org.apache.hadoop.hive.ql.parse.SemanticException: Database does not exist: test_db 回答 这种情况通常在试图

查看更多 →

__col2 回答 这种情况通常会发生当您试图使用HiveSyncTool.java类向现有hive表添加新列时。数据库通常不允许将列数据类型按照从高到低的顺序修改，或者数据类型可能与表中已存储/将要存储的数据冲突。如果要修复相同的问题，请尝试设置以下属性： 设置hive.metastore

查看更多 →

读取redis数据报超时错误 问题描述 读取redis数据报超时错误：redis server response timeout（3000ms） occurred after 3 retry attempts。 问题排查 根据报错后的提示，将客户端超时时间改大一些。 确认问题发生

查看更多 →

非联通用户请查看 设备接入服务 。Demo代码是调用SDK接口的样例代码，包括初始化及各个接口调用，仅供开发者参考。SDK提供Python方法调用物联网平台的API接口与平台通信。消息推送回调使用Python代码实现回调接口，供平台推送消息给应用 服务器 时调用，应用通过继承PushMessageReceiver类并重写类中的方法接收推送消息的内

查看更多 →

SDK使用说明 数据订阅功能将数据库中关键业务的数据变化信息缓存并提供统一的SDK接口，方便下游业务订阅、获取、并消费。 在使用SDK消费之前，需要先在 数据复制服务 控制台创建数据订阅任务。 当订阅任务创建完成后，使用SDK可以实时订阅订阅通道中的增量数据。目前： 数据复制服务只提供JAVA版本SDK，SDK下载地址。

查看更多 →

资源监控使用说明 满足内置发现规则的服务，安装ICAgent后该服务会自动被发现；对于不满足内置应用发现规则的服务，您则需配置应用发现规则。 资源监控使用说明如下： 图1 资源监控使用说明 父主题： 资源监控

查看更多 →

删除实例 只有自建大数据实例支持删除，且授权数据库为0才可删除。 勾选多个自建大数据实例，单击实例列表左上角“批量删除”，删除实例。也可通过单击实例列表“操作”列的“删除”，删除单个实例。 拉取实例下的元数据 MRS_Hive实例下数据库授权个数大于0时，在Hive实例列表“操作”列，单击“更多

查看更多 →

printStackTrace(); } return passWord; 连接成功后，设备显示在线。 图1 设备列表-设备在线 注：如果连接失败，在onFailure函数中已实现退避重连，代码样例如下： @Override public void onFailure(IMqttToken

查看更多 →

Android Demo使用说明 概述 本文以Android语言为例，介绍通过MQTTS/MQTT协议接入平台，基于平台接口实现“属性上报”、“订阅接收命令”等功能。 本文中使用的代码为样例代码，仅用于体验平台通信功能，如需进行商用，可以参考资源获取获取对应语言的IoT Device

查看更多 →

问监测。可通过设置Kafka服务配置参数“ssl.mode.enable”为“true”，来启动SSL和SASL_SSL两种协议类型。 下表是四种协议类型的简单说明： 协议类型 说明 支持的API 默认端口 PLAINTEXT 支持无认证的明文访问 新API和旧API 9092 SASL_PLAINTEXT

查看更多 →

Python SDK使用说明 操作场景 使用Python语言调用APP认证的API时，您需要先获取SDK，然后新建工程，最后参考调用API示例调用API。 前提条件 已获取API的调用信息，具体请参见开发准备。 已安装开发工具和Python开发语言环境，具体请参见开发准备。 Py

查看更多 →