回答情况：
提问时间：
问题标签：
我们知道Flink是一个真正的实时流处理引擎，它可以在记录到达时处理记录，我们也知道火花流是一个微批量流处理引擎。
然而，我们也知道星星之火发布了结构化的流媒体，它怎么样？它是否也是一个真正的实时流处理引擎，就像Flink一样，它可以在记录到达时立即处理记录，而不是微批处理，或者仍然使用微批处理模式？
浏览 3修改于2017-06-29得票数 3
回答已采纳
使用这个被操纵的框架，我正在尝试使用Azure服务进行实时流。
我浏览了微软的文档，但没有找到任何相关的信息来使用这个框架执行实时流。
浏览 2提问于2022-04-13得票数 -1
问题上下文许多其他帖子建议您可以使用thin进行服务器附带事件(sse)，如果您通过exec thin start --threaded：和、Aaron的开创性和Ryan的长期可靠的启动它。但是，即使我正在复制Railscast示例，我也无法让它与thin一起工作。# -----------------------------------------------
浏览 1修改于2017-05-23得票数 6
回答已采纳
我关注的是通过GCD发布/订阅的物联网实时流处理，云数据流和通过BigQuery.I执行分析。我正在寻求如何实现这一点的帮助。
浏览 2修改于2017-09-28得票数 1
我的意图是继续从我的个人电脑上的输入数据，并处理实时的数据。在这个回调中对音频数据进行所有处理是不是很糟糕我的主函数可以轮询此标志，然后在主函数中执行处理。
然而，我担心的是
浏览 3提问于2016-10-13得票数 2
嗨，如何在java脚本中流实时的czml数据包和进程，而不使UI冻结，并且从一开始就不启动场景，每当我从具有新更新的笛卡儿坐标的服务器发送新的czml数据包，以及从纪元时间开始的时间和经过的秒时，整个场景将在处理数据包后从一开始就重新启动基本上，我希望场景中的对象能够实时移动，其中实时笛卡尔坐标是从服务器输入的。
浏览 4修改于2016-10-05得票数 2
回答已采纳
我想将视频从本地服务器广播到iPhone。我只得到链接，这是来自网络服务与任何扩展的视频。喜欢:@"avi",@"wmv",@"rmvb",@"flv",@"f4v",@"swf",@"mkv",@"dat",@"vob",@"mts",@"ogg",@"mpg",@"wma"1)MPMovieplaycontroller或
浏览 6修改于2014-03-13得票数 0
回答已采纳
我渴望了解更多关于处理实时视频流(不是点播或录制的流)的知识。有没有人可以推荐的好书或网站？
我不希望建立一个媒体播放器。我想使用C++/C打开一个Flash媒体流，然后处理该数据；例如，将其拆分成4KB大小的片段，然后重新发送给另一个客户端。
浏览 6修改于2012-06-02得票数 0
我正在开发的应用程序与一个数字音频设备进行通信，它能够同时发送24个不同的语音流。该设备通过USB接口连接，使用FTDI设备(串口仿真器)和D2XX驱动程序(基本的COM驱动程序来慢处理4.5Mbit的传输)。应用程序由3个线程组成：
主线程-图形用户界面、控件等.总线读取器--在此线程中，数据不断从设备读取并保存到文件缓冲区(此线程中没有逻辑)数据解释器--该线程从文件缓冲区读取数据，转换为示例，进行简单的样本处理第二个问题是，文件缓冲区对于长记录来说真的很重，在数据处理结束之前，我无法清除这个缓冲区(这会进一步减慢<e
浏览 0修改于2010-03-29得票数 0
回答已采纳
在我的Windows 8商店应用程序中，我倾向于执行实时视频流处理(例如人脸检测)。
在我以前的Windows 7应用程序中，我能够使用以下技术()执行实时视频处理。从那里，我可以执行图像处理。，它们大多使用内置处理功能。如果您想实时处理视频或覆盖其他用户界面组件-输入…
有没有提示如
浏览 3修改于2014-05-19得票数 1
回答已采纳
我想实现一个实时Spark，它可以每分钟读取网络日志，从Kafka获取大约1GB的JSON日志行/分钟，最后将聚合的值存储在ElasticSearch中。如果我将轮询时间从30秒增加到60秒，那么聚合需要大量时间，因此根本不需要实时。
我希望以这样一种方式来实现它，即在ElasticSearch中，每个键只保存一行。
浏览 3提问于2016-04-19得票数 0
1回答
我正在尝试处理一个实时的电子邮件流，我对BASH很熟悉。我试图弄清楚如何将每一封电子邮件写到它自己独特的文件中。在那里，我可以根据自己的需要处理JSON。*例子*将打开流并开始侦听"to\":\"guy@mail.com\&qu
浏览 1修改于2015-01-19得票数 0
回答已采纳
2回答
假设worker 1正在处理job 1，它将生成其他works所依赖的数据输出。到目前为止，我已经看到了spark流实时处理，但流通信似乎没有发生在工人之间？任何方向或建议都将不胜感激。
浏览 1提问于2015-07-06得票数 0
1回答
我们正在寻找大容量的实时视频流。
目前，我们正在使用Kafka Python，它通过主题和mongo发送uuid来存储大型数据和uuid。在消费者端，我们根据获取的相关帧数据fr mongo接收uuid，然后传递到处理。
浏览 8修改于2022-06-21得票数 0
on_stderr=on_stderr return proc.wait()
当然，asyncprocess是一些虚构的进程模块，它允许我启动子进程并传递stdout和stderr的处理程序函数
浏览 2提问于2015-03-04得票数 2
我正在尝试使用Process从我的C#项目中调用rclone，并且还需要从该过程中获得实时输出。 为了实现这一点，我使用下面的代码，可以找到下面的代码： 它是从this post上取来的。logHandler.loadLogFromBuffer(); logHandler.writeToLog(data);};
stdOut.Start(); 然而，我遇到的问题是流的第一个字节(来自Transferring:...的T消息)与流的其余部分分开输出。
浏览 97提问于2021-07-03得票数 0
1回答
我正在做一个项目，以实时检测网络用户活动中的异常.必须实时检测用户的任何恶意或恶意活动。输入数据是用户的点击流数据。我使用python 3.6，我有以下查询，
作为进行数据预处理的最佳方法，考虑到数据集中的所有属性都是分类的，可以应用热编码或标签编码等values.Encoding方法，但必须对数据进行实时处理，因此很难按照项目我真的很困惑如何处理数据预处理。如有任何见解或建议，将不胜感激。
浏览 1提问于2021-06-22得票数 0
我让它和Puma一起工作，但是瘦的时候我没有得到任何流输出，我必须杀死服务器才能停止它。我想，在这样的应用程序中，如果没有数千名用户同时连接到一个流中，就会很容易地受到骚扰。美洲狮在这里会有多大的规模？我读到美洲豹每个连接使用一个线程。这有效率吗？那瘦呢？所有的连接都在同一个线程中吗？
浏览 0提问于2013-03-15得票数 7
我已经收到了使用jnetpcap的实时数据包。谁能告诉我如何使用spark streaming从实时数据包中提取数据包头和其他详细信息？
浏览 4修改于2014-09-29得票数 0
在实践中，小批处理和实时流有什么区别(不是理论)？理论上，我理解迷你批处理是在给定的时间范围内批处理的，而实时流更像是在数据到达时做一些事情，但我最大的问题是为什么不使用带有epsilon时间框架的小批处理(例如1毫秒)，或者我想了解为什么一个小批处理比其他的解决方案更有效我最近遇到了一个例子，其中迷你批处理(Apache )用于欺诈检测，实时流(Apache )用于预防欺诈。还有
浏览 8修改于2017-04-09得票数 24
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号