UA配置”页签，勾选需要下发的OPC UA连接点，单击“下发策略”按钮。 配置规则引擎。 配置普通设备采集上来的数据转发到MQS。 在规则引擎界面单击“创建规则”按钮，规则引擎所属应用需要与普通产品相同。 单击规则引擎名称进入规则引擎详情页面，配置数据源端和数据目的端。 数据源端选择之前创建的产品和设备。

查看更多 →

选需要下发的Modbus连接点，单击“下发策略”按钮。 配置规则引擎。 配置普通设备采集上来的数据转发到MQS。 在规则引擎界面单击“创建规则”按钮，规则引擎所属应用需要与普通产品相同。 · 单击规则引擎名称进入规则引擎详情页面，配置数据源端和数据目的端。 数据源端选择之前创建的产品和设备。

查看更多 →

RDD$$anonfun$partitions$2.apply(RDD.scala:237) at scala.Option.getOrElse(Option.scala:120) at org.apache.spark.rdd.RDD.partitions(RDD.scala:237) at org.apache

查看更多 →

设备集成API（V1） 产品管理 设备管理 规则引擎 父主题： 历史API

查看更多 →

设备集成API 设备分组管理 设备管理 订阅管理 产品模板 产品管理 规则引擎 服务管理

查看更多 →

图1 Spark架构 Spark开发接口简介 Spark支持使用Scala、Java和Python语言进行程序开发，由于Spark本身是由Scala语言开发出来的，且Scala语言具有简洁易懂的特性，推荐用户使用Scala语言进行Spark应用程序开发。 按不同的语言分，Spark的API接口如表1所示。

查看更多 →

物联网解决方案 物联网平台支持终端设备直接接入，也可以通过工业网关或者家庭网关接入。物联网平台支持多网络接入、多协议接入、系列化Agent接入，解决设备接入复杂多样化和碎片化难题，也提供了丰富完备的设备管理能力，简化海量设备管理复杂性，提升管理效率。IoT设备接入云服务支持的特性详见下表。

查看更多 →

Connect对传统停车场的管理系统进行数字化改造，实现停车场车辆进出、计费、停车位状态的智能化管理。 停车场车位感应设备和进出门闸设备通过设备集成连接到ROMA Connect，实时上报车位状态信息和车辆出入信息。 设备上报的数据经规则引擎转发到消息集成的Topic上存储。 通过数

查看更多 →

apply(KafkaCluster.scala:366) org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply(KafkaCluster.scala:366) scala.util.Either.fold(Either

查看更多 →

网络环境较好的地方。 解决方案二：多个厂家的充电桩设备数据通过IoTEdge进行采集，可以在边缘节点部署协议插件应用屏蔽多个厂商的各种私有化协议，边缘节点还可以部署一些简单的业务计算应用，减少与云端的交互，边缘网关通过MQTT协议统一上报数据到云端IoTDA。云端IoTDA可将数

查看更多 →

使用Sbt构建 使用Sbt工具构建Scala和Java项目。 图形化构建 在配置构建步骤中，添加“Sbt构建”构建步骤。 参数说明如下： 参数项 说明 步骤显示名称 构建步骤的名称，可自定义修改。 工具版本 默认版本为sbt1.3.2-jdk1.8，当前仅支持该版本。 命令 配置

查看更多 →

readObject(JavaSerializer.scala:71) at org.apache.spark.serializer.JavaSerializerInstance.deserialize(JavaSerializer.scala:91) at org.apache.spark

查看更多 →

'hello' when 4 then 'bye' end FROM item WHERE a >= b+c" 规则引擎还提供多种函数，您可以在编写SQL时使用它们，从而实现多样化数据处理。您可以在SQL语句中，使用函数获取数据或者对数据做处理。例如，SELECT service，ab

查看更多 →

for the new Scala SDK”页面单击“Browse...”。 图22 Select JAR's for the new Scala SDK 在“Scala SDK files”页面选择scala sdk目录，单击“OK”。 图23 Scala SDK files 设置成功，单击“OK”保存设置。

查看更多 →

getChildren(ZkUtils.scala:541) at kafka.utils.ZkUtils.getSortedBrokerList(ZkUtils.scala:176) at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:235)

查看更多 →

next(ShuffleBlockFetcherIterator.scala:51) at scala.collection.Iterator$$anon$11.next(Iterator.scala:328) at scala.collection.Iterator$$anon$13

查看更多 →

DWS-Connector版本说明 表1 版本变更记录 版本 变更描述 备注 1.0 初始化版本。 dws-connector-flink仅发布Scala2.11 Flink 1.12版本 1.0.2 dwsclient优化异常重试逻辑，由所有异常重试修改为只重试：连接异常、数据

查看更多 →

设备集成指导 业务使用介绍 创建产品 注册设备 接入设备 产品管理 设备管理 规则引擎 订阅管理

查看更多 →

for the new Scala SDK”页面单击“Browse...”。 图20 Select JAR's for the new Scala SDK 在“Scala SDK files”页面选择scala sdk目录，单击“OK”。 图21 Scala SDK files 设置成功，单击“OK”保存设置。

查看更多 →

for the new Scala SDK”页面单击“Browse...”。 图20 Select JAR's for the new Scala SDK 在“Scala SDK files”页面选择scala sdk目录，单击“OK”。 图21 Scala SDK files 设置成功，单击“OK”保存设置。

查看更多 →

数据转发至第三方应用 转发方式概述 使用HTTP/HTTPS转发 使用AMQP转发 使用MQTT转发 设备间通信 父主题： 规则引擎

查看更多 →