Wait(); 发布Topic后，Demo界面显示如下： 设备上报属性成功后可在设备详情页面查看到上报的属性： 图2 查看上报数据-Demo_smokeDetector 如果在“设备详情”页面没有最新上报数据，请确认设备上报的服务/属性和产品模型中的服务/属性一致。 由于是同步命令需要端侧回复响应可参考接口。

查看更多 →

Android/Windows/Mac/Electron Demo资源下载路径”中下载的Demo包； 2.下载Demo包到本地； 3.打开本地命令提示符框，输入如下命令，在本地生成已下载的Demo包的SHA256值，其中，“D:\hmwsdk-win-demo-win32.zip”为SDK包的本地存放路径和SDK包名，请根据实际情况修改。

查看更多 →

Spark Spark基本原理 Spark HA方案介绍 Spark与其他组件的关系 Spark开源增强特性 父主题： 组件介绍

查看更多 →

白板加速SDK是基于IdeaHub产品中的FastPen进行构建的，对外提供白板加速相关功能接口，为客户白板提供笔迹跟手的加速功能，打造低时延极致白板体验。例如，APP需要提升白板书写体验，可以参考Demo进行白板加速。 https://gitee.com/ideahub/pen-speed

查看更多 →

购买E CS ，ECS的操作系统需为APM支持的操作系统。 如果您不想购买ECS，请跳过下述步骤，直接了解APM功能。 为保证性能，建议您购买时“vCPU”请选择2核及以上，“内存”请选择4GB及以上。 使用ECS提供的远程登录功能以root用户登录ECS。 创建应用目录并进入目录，以目录testdemo为例。

查看更多 →

Connect实例的消息集成在开启SASL_SSL的同时，也开启了VPC内网明文访问，则VPC内无法使用SASL方式连接消息集成的Topic。 使用SASL方式连接消息集成的Topic时，建议在客户端所在主机的“/etc/hosts”文件中配置host和IP的映射关系，否则会引入时延。

查看更多 →

GO Demo使用说明 本文以Go语言为例，介绍应用通过MQ TTS 协议接入平台，接收服务端订阅消息的示例。 前提条件 熟悉Go语言开发环境配置，熟悉Go语言基本语法。 开发环境 本示例使用了Go 1.18版本。 添加依赖 本示例使用的Go语言的Mqtt依赖为paho.mqtt.golang（本示例使用版本为v1

查看更多 →

IoT_device_demo：使用MQTT协议的demo文件; message_sample.py：设备发送消息和接收平台消息的demo； command_sample.py：响应平台下发命令的demo； properties_sample.py：属性上报等的demo； IoT_de

查看更多 →

"content":"很不错的一款车，可以改变生活方式。", "type": 2 } Python3语言请求代码示例（分析汽车领域用户评论为“浑浑噩噩的头脑、失魂落魄的身体…”的情感） # -*- coding: utf-8 -*- # 此demo仅供测试

查看更多 →

单击“提交”完成弹性资源池的创建。 在弹性资源池的列表页，选择要操作的弹性资源池，单击操作列的“添加队列”。 配置队列的基础配置，具体参数信息如下。 表4 弹性资源池添加队列基础配置 参数名称 参数说明 配置样例 名称 弹性资源池添加的队列名称。 dli_queue_01 类型 选择创建的队列类型。

查看更多 →

汽车行业场景 应用场景 随着车联网等新业务场景的出现，汽车的数字化营销、智慧生产、智慧门店等新兴场景不断涌现，传统汽车行业的数字化转型成为产业发展趋势，但是与此同时也面临着多种挑战。 挑战一：传统稳态业务资源利用率不高，基础资源无法有效整合。 挑战二：弹性能力不足，无法满足大量在线用户并发接入，网络时延较高。

查看更多 →

shuffle Service是长期存在于NodeManager进程中的一个辅助服务。通过该服务来抓取shuffle数据，减少了Executor的压力，在Executor GC的时候也不会影响其他Executor的任务运行。 操作步骤 在NodeManager中启动External

查看更多 →

Executor执行这些Task，将具体RDD的数据写入到步骤1创建的目录下。 Spark和YARN的关系 Spark的计算调度方式，可以通过YARN的模式实现。Spark共享YARN集群提供丰富的计算资源，将任务分布式的运行起来。Spark on YARN分两种模式：YARN Cluster和YARN

查看更多 →

//IoT平台mqtt对接地址（要替换为设备所在的平台 域名 地址） var serverUrl = "xxx.myhuaweicloud.com"; //请填写设备所在平台的接入地址 //注册设备时获得的deviceId,密钥（要替换为自己注册的设备ID与密钥） var deviceId

查看更多 →

Node.js Demo使用说明 本文以Node.js语言为例，介绍应用通过MQTTS协议接入平台，接收服务端订阅消息的示例。 前提条件 熟悉Node.js语言开发环境配置，熟悉Node.js语言基本语法。 开发环境 本示例所使用的开发环境为Node.js v13.14.0版本。请前往Node

查看更多 →

MRS 集群客户端如何通过AK/SK信息对接OBS MRS 1.9.2及之后的版本支持使用obs://的方式对接OBS服务，当前主要支持的组件为Hadoop、Hive、Spark、Presto、Flink。其中HBase组件使用obs://的方式对接OBS服务暂不支持。 该章节主要介绍MRS集群组件如何通过AK/SK（Access

查看更多 →

C# Demo使用说明 本文以C#语言为例，介绍应用通过MQTTS协议接入平台，接收服务端订阅消息的示例。 前提条件 熟悉.NETFramework开发环境配置，熟悉C#语言基本语法。 开发环境 本示例所使用的开发环境为.NETFramework 4.6.2版本，.Net SDK

查看更多 →

有使用编译器中的IP，原因是Chrome 47以后，getUserMedia API只能允许来自“安全可信”的客户端的视频音频请求，如https和本地的localhost。如果页面的脚本从一个非安全源加载，Chrome会抛出错误。 使用Demo入会 浏览器Demo展示如下图： 图5

查看更多 →

Spark输入 概述 “Spark输入”算子，将SparkSQL表的指定列转换成同等数量的输入字段。 输入与输出 输入：SparkSQL表列 输出：字段 参数说明 表1 算子参数说明 参数 含义 类型 是否必填 默认值 Spark数据库 SparkSQL的数据库名称。 String

查看更多 →

Spark输出 概述 “Spark输出”算子，用于配置已生成的字段输出到SparkSQL表的列。 输入与输出 输入：需要输出的字段 输出：SparkSQL表 参数说明 表1 算子参数说明 参数 含义 类型 是否必填 默认值 Spark文件存储格式 配置SparkSQL表文件的存储

查看更多 →

使用Spark 运行Spark应用时修改split值报错 提交Spark任务时提示参数格式错误 磁盘容量不足导致Spark、Hive和Yarn服务不可用 引入jar包不正确导致Spark任务无法运行 Spark任务由于内存不够或提交作业时未添加Jar包，作业卡住 提交Spark任务

查看更多 →