我正在用Java/Python构建一个使用kafka和Kafka流的产品。
该产品将处理来自几个不同外部数据源的数据，这些数据源包括实时事件和每小时批处理事件。可能会有很长的差距，几个小时在一起，没有任何事件将来自外部来源。其中一些来自不同来源的事件需要进行关联和聚合，为此我计划使用Kafka流。鉴于Kafka
浏览 1提问于2019-05-16得票数 1
我刚接触Python (和计算机编程)，但对于我的雇主，我设置了一个Python脚本，当新数据来自流来源时，更新30个不同的变量。在一个随变量变化而更新的表格中显示这30个变量的最佳或最简单的方法是什么？
目前，我让脚本在每次变量发生变化时向控制台打印一个新的表，这会给我留下一个巨大的表集合，我假设有更好的方法来做到这一点。
浏览 8提问于2018-02-14得票数 0
回答已采纳
1回答
骡子流-跟踪流之间的路径
、、、、
向我提供了大量包含mule流的xml文件，并要求我理解流程并绘制图表，显示流之间的消息路径。
在查看这些流时，我看到了入站端点，一些日志/转换，然后是出站端点。我的问题是如何确定入站端点的来源？这些入站端点是否作为来自其他流的出站端点，如果它们是，我应该寻找什么来确定它们来自和将要流向的流。
浏览 3提问于2017-06-09得票数 0
回答已采纳
我开始使用进行批处理和流处理。正在开发的工作主要用于摄取来自不同来源(MySQL、Kafka和文件系统)的数据，清理它们，进行流和沐浴聚合，并将其写回。考虑到这些任务，是否有使用Java 或Python 编写作业的建议？他们之间在性能和功能方面有什么明显的差异吗？
例如，我注意到对于Java，内置的I/O PTransform JdbcIO是可用的。这个PTransfor
浏览 3提问于2020-07-07得票数 0
回答已采纳
我计划用Google平台准备一个无服务器的数据管道。我的计划是使用Dataflow/ Dataproc处理来自三个不同来源的批处理数据。我的输入来源是：
但是在阅读了他们的文档之后，我得到了他们没有任何关于cloud或MongoDB的输入。此外，我已经检查了他们的自定义驱动程
浏览 0提问于2018-06-11得票数 0
2回答
嗨,但是，我需要帮助的是如何在Python中接收视频流并进行处理。如何访问从webRTC流到Python后台的视频源？ vi
浏览 11提问于2018-11-07得票数 11
回答已采纳
我应该如何以这样的方式将来自一个程序的输出流式传输到数量不确定的程序，使得数据不会在任何地方缓冲，并且流来源的应用程序即使没有读取流也不会阻塞，但是如果没有来自第一个提到的程序的输出，则读取流的程序确实会阻塞我已经尝试用谷歌搜索了一段时间，但我发现的所有方法都是，如果没有读取流，程序就会阻塞。
浏览 1提问于2012-12-27得票数 1
我正在尝试处理来自从服务器接收的媒体流对象的远程音频。我正在获取多个媒体流对象，这些对象被传递到video element srcObject，然后被静音。(就像视频会议一样)每个媒体流对象都被传递到一个单独的组件，该组件具有唯一的video元素并附加到该组件。我想单独处理每个媒体流对象的音频，并相应地处理它以显示必要的视觉效果。问题是，假设呼叫中有5个用户，任何随机用户发言，分析
浏览 31提问于2021-05-19得票数 1
2回答
通常，应该使用流从数据库中获取数据，然后使用流将其发送到Apache，等等。我的意思是，数据应该从头到尾都是流格式。然而，我的数据库代码并不是以流的形式编写的，它们有来自不同类型的数据库的复杂来源。因此，我需要像这个getData(int page, int perPage)一样查询我
浏览 4提问于2019-12-21得票数 3
回答已采纳
3回答
ASP.net连续响应流
、、、
我想知道如何才能发送一个连续的响应流，而不会最终关闭它。为了更好地解释我的问题，可以将asp页面看作一个代理，它中继来自不同来源的第三方流(由另一个来源广播的音频流或视频流)。显然，Response.Write()或Response.BinaryWrite()将我限制为一个预定义的源。
提前谢谢。
浏览 0提问于2009-08-12得票数 2
我正在以缓冲的字节序列(例如一次1024字节)从流中读取数据，并在将其写回相同类型的流之前进行一些比较、检查或处理。
目前，数据来自文件。但将来它可能来自其他来源(内存文件、TCP等)。有我能实现的设计模式吗？还是没有这个必要？
浏览 0提问于2014-03-26得票数 1
回答已采纳
据我所读，Spark是对流数据进行实时分析的一个很好的用例，然后这些数据可以被推入下游的接收器，如hdfs/hive/hbase等等。
我对此有两个问题。我不清楚是否只有一个火花流作业运行或多次在任何给定的时间。假设我有不同的分析，我需要对卡夫卡的每一个话题或每一个流进卡夫卡的源进行分析，然后把这些结果推到下游。是否允许您并行运行多个流作业，以便为每个流保持聚合
浏览 9提问于2017-01-12得票数 4
回答已采纳
1回答
只绑定生产者的Kafka流
、、、、
我的应用程序需要基于REST请求将记录列表发布到Kafka主题。是否可以使用KafkaStream发布主题上的项目列表而不消耗任何东西？
浏览 8提问于2022-11-17得票数 0
3回答
它记录任何发送到扬声器的音频，无论数据流是来自web还是来自某个文件或麦克风。我可以在桌面应用程序中制作这样的应用程序吗?我可以录制发送到我的扬声器的流，而不考虑来源。？
浏览 2提问于2012-04-16得票数 3
回答已采纳
我想覆盖在workflow Foundation 4工作流中用作变量和参数的自定义对象的默认持久性。我知道WF4使用NetDataContractSerializer持久化自定义对象。然而，我的对象不是简单的POCOs。它们更像是链接到数据库的"ActiveRecord“对象。因此，我想覆盖持久化过程，以便根据需要将这些对象存储到数据库中或从数据库加载这些对象
我尝试过实现ISerializable，但显然，它不起作用。wo
浏览 1提问于2014-10-13得票数 0
我在python中有一个随机整数程序，它将随机整数张贴到Azure SQL数据库中，Azure SQL数据库中的数据正在实时更新，我想将这些数据流到中。不幸的是，这个数据只能每1分钟流一次，这是慢的方法。因此，我正在考虑在streaming中使用流输入，例如Azure Blob存储或事件集线器。有谁知道我如何传输和流我的实时数据
浏览 0提问于2019-07-19得票数 0
回答已采纳
我正在构建Nodejs RestAPI和Python应用程序，我想知道是否有一种在数据库(MongoDB)更改后接收应用程序更新的有效方法
我考虑过每隔几秒钟发送一次API请求，并检查是否有任何更改，但我认为这对大规模实现来说并不好
浏览 1提问于2019-08-02得票数 0
回答已采纳
android可以同时处理来自多个来源的媒体流吗？假设我有一个来自麦克风的音频流和另一个来自sdcard中的视频的音频流，并且想要向她播放它们。
浏览 2提问于2014-06-21得票数 0
1回答
我的工作涉及到大量的数据处理和流处理，处理来自不同来源的数据--经常是很多次--数据。我什么都用Python，我想知道我应该研究Python的哪个领域，以便优化和构建批处理管道？到目前为止，我所知道的唯一一件事是研究生成器和懒惰的评估，但我想知道在python中我还可以使用哪些其他概念和库来进行高效的批处理。一
浏览 3提问于2014-10-09得票数 3
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号