1回答
MQTT结构化流
、、、
我正在尝试将Spark Streaming设置为读取MQTT源，但当我收到第二条消息时，它会启动一个异常。我有以下代码：import org.apache.commons.io.FileUtils// Read text from socket
val lines = spark.readStream.format("org.apache.bahir.sql.streaming
浏览 10提问于2017-01-17得票数 1
回答已采纳
2回答
我使用MQTT在Arduino上将传感器数据发送到Javascript页面。我可以使用什么格式来发送更复杂的结构化数据？例如：我想把它发到一条MQTT信息上。
浏览 1提问于2014-08-22得票数 2
当Spark结构化流代码时，我将得到以下异常
.readStream
.format("org.apache.bahir.sql.streaming.mqtt.MQTTSt
浏览 1提问于2018-12-05得票数 1
回答已采纳
3回答
我使用Spark结构化流API从MQTT流源读取数据。val lines:= spark.readStream .option("clientId", "employee11")
.load("tcp://localhost:8000&
浏览 0提问于2018-12-05得票数 2
回答已采纳
我正在尝试将一个ApacheSpark结构化流连接到一个MQTT主题(在这个例子中，IBM平台在IBM上)。我创建结构化流如下所示： .format("org.apache.bahir.sql.streaming.mqtt.MQTTStreamSourceProvider所以这个问题已经解决了，但是如果我开始使用以下行从流中读取：
val = df.writeStream。JSON表示的字符串对象流</em
浏览 5提问于2017-02-06得票数 0
回答已采纳
1回答
如何在Node.js中解压gz码流？我正在尝试使用MQTT解析gz流(一个数据文件)。我的代码看起来像这样, client = mqtt.createClient('1883','mqttserver');client.on('message', f
浏览 3提问于2013-07-30得票数 2
2回答
视频流(像50Kbps这样的低比特率)可以在IoT协议上实现吗?与HTTP/RTP或TCP/UDP流相比，它的性能要好得多。或者底层视频流架构对使用CoAP/MQTT的用例没有帮助。我问这个问题是因为我找不到关于IoT协议上的视频流的好资源。请帮帮忙。
浏览 4提问于2015-12-02得票数 14
我正在尝试将Apache结构化流连接到一个MQTT主题(本例中是IBM平台上的IBM)。我创建结构化流如下所示： .format("org.apache.bahir.sql.streaming.mqtt.MQTTStreamSourceProvider我以如下方式返回这个df对象：但是
浏览 5提问于2017-02-03得票数 0
回答已采纳
我使用Apache结构化流。结构化流是建立在Spark引擎上的可伸缩和容错的流处理引擎。由于它构建在Spark引擎上，这是否意味着spark.sql.adaptive.enabled适用于火花结构化流？
浏览 7提问于2022-04-30得票数 -1
1回答
我无法看到我通过MQTT/蚊子流接收到的东西，通过echoing。#!/bin/bash
第一行订阅mqtt流</em
浏览 3提问于2015-04-10得票数 0
我正试着让我的Alexa从MQTT broker那里获取读数，然后在我问她要温度的时候告诉我。我可以让她读取我设置的读数，但当它来自读数传感器并告诉我数字时，它没有显示任何信息。
浏览 2提问于2017-04-27得票数 0
1回答
当我将结构化流应用于静态数据集时，火花引擎将得到静态数据集的全部数据。在这种情况下，使用流处理静态数据集意味着什么？我所期望的是结构化流能够一次获得整个数据集的一部分，然后我在数据集中的这一部分上计算它，直到整个数据集被遍历。否则，使用结构化流和spark SQL处理静态数据集是完全相同的。对静态数据集使用结构化流的原因是静态数据集可能很大。我们希望使用结构化流来防止静态数据集上的数据一次性加载到内存中(因此内存非常
浏览 4提问于2019-11-15得票数 2
回答已采纳
8回答
我想做多个聚合在星火结构化流。就像这样：
当我在结构化流中运行时，它会给出一个错误：“流DataFrames/Datasets不支持多个流聚合”。是否有一种方法可以在结构化流中实现这样的多个聚合？
浏览 14提问于2016-12-07得票数 21
1回答
我正在尝试构建一个实时的mqtt应用程序，它将数据从移动设备发送到处理该数据的后端。如何在这些mqtt流中最好地实现标识？我的意思是，我怎么知道来自哪个设备/用户的数据？我应该创建多个流，还是应该在标识用户的流中添加一个变量？
浏览 2提问于2013-12-25得票数 0
回答已采纳
1回答
我正在尝试设置一个反向代理，将localhost:8081解析为安装在另一台计算机上的代理。我的Nginx配置文件是： worker_connections 1024; listen 8081; proxy_pass tcp://192.168.1.177:1883;} mosquitto_sub -h local
浏览 7提问于2022-03-07得票数 2
通过Mqtt传输大量数据(即每片数据约100 to )是否是一个不错的选择？补充:据我所知，mqtt似乎可以支持多达256 As的规范。
浏览 3提问于2021-06-20得票数 0
回答已采纳
1回答
我正在尝试使用paho mqtt客户端订阅carriots数据流。但我无法读取carriots的任何数据。这是我用来订阅carriots的源代码。# -*- coding: utf-8 -*- # sub_carriot.pyimport paho.mqtt.subscribe as mqtt
浏览 9提问于2016-07-21得票数 0
因此，我想将数据从Nifi直接发送到流引擎。但是，我不知道一些细节。例如，；Storm有Nifi Bolt。但是，如果流引擎集群中的任何节点出现故障，我不想丢失数据.
这是可能的星火结
浏览 0提问于2019-02-14得票数 0
回答已采纳
我用spring创建了流，比如-创建并部署新流“mqtttestfile”。我还检查了localhost:9393/admin-ui，成功创建和部署了流。
我的MQTT代理运行在localh
浏览 2提问于2017-03-04得票数 0
回答已采纳
对于Message属性，我已将值设置为${mqtt.message}和${负载}。我希望发送由publisher发送的消息的有效负载中的字符串消息。
浏览 3提问于2017-11-01得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
腾讯会议
腾讯云开发者
