问题标签 [data-stream]

我正在开发一个处理图像的应用程序。拥有一个 HTML 前端，我必须从网络摄像头捕获图像（使用视频标签）并将它们连续发送到服务器。然后将分析图像，并在检测到对象时 (x, y, z) 点将被发送回客户端。

我现在有 2 个近似值：

1.- 不断捕获帧（使用不可见的画布并先前加载帧）并使用 Base64 编码将它们发送到服务器。（例如使用 HTML5 和 JavaScript 从视频中捕获帧）
优点：
- 易于实现。

缺点：
- 非常慢。许多图像将被连续发送，并且应该非常快速地处理。（在这种情况下，图像必须在到达时保存并在处理后删除）

2.- 发送视频流并处理服务器中的所有帧。
优点：
- 数据发送速度非常快。

缺点：
- 复杂。我不知道如何实现它。

关于如何制作的任何提示？

我正在尝试为我一直在编写operator>>的自定义类重载，代码如下：PriorityQueue

这目前适用于stdin或std::cin输入，但它不适用于fstream输入 - 第一个getline总是从输入中读取一个空行，这样while循环永远不会被触发，而且我似乎无法跳过它（我尽可能inStream.ignore()尝试见上文，但这不起作用。

编辑：

目前我只是想让它适用于文件输入，而忽略了它现在只适用于int数据类型和优先级类型的事实——这些是不相关的（对象本身double的实际操作也不是）。targetQueue

目前，我只关心在尝试通过文件输入流式传输时解决空行问题。

要传递的示例文件：

其中每行上的数字是\t分开的。

示例测试：

其中“test.txt”是上面示例文件的格式。

编辑：更简单的例子

代码：

我有一个按升序排列的整数输入流，我的任务是动态地从该流中创建一个平衡二叉搜索树。我已经浏览了链接：来自整数流的 BBST，并了解我们可以使用红黑树。问题是，我正在寻找更优化的解决方案，这些解决方案使用输入数据中的“排序信息”。

这是我的第一个问题，我现在被困在这个未知问题上。该应用程序成功运行，直到我添加了一些新代码来制作自定义列表视图组件并从客户端读取一些消息。

MainActivity.java

我的自定义适配器

content_main.xml

和 layout_list_item.xml

我是 android 新手，其中很多代码来自一些 android-er 帖子和一些来自以前的 stackoverflow 答案。如果有人能告诉我为什么我的应用程序在启动时崩溃。

编辑：解决了错误，但现在在客户端的 ASyncTAsk 中出现异常，在客户端应用程序的 doInBackground() 的 doInBackground() 代码中

我正在尝试在 python 中重新创建一个函数，以估计数据流的第二时刻。

正如 Ullman 的书“海量数据集的挖掘”所述，第二个时刻：

是 m_i 的平方和。它有时被称为惊奇数，因为它衡量了流中元素分布的不均匀程度。

其中 m_i 元素是流中的唯一元素。

例如，有这个玩具问题\数据流：

我们这样计算第二个时刻：

（因为“a”在数据流中出现 5 次，“b”出现 4 次，依此类推）

因为我们无法将所有数据流存储在内存中，所以我们可以使用一种算法来估计二阶矩：

Alon-Matias-Szegedy 算法（AMS 算法） ，使用以下公式估计二阶矩：

其中 X 是流的一个单义元素，随机选择，X.value 是一个计数器，当我们读取流时，每次遇到从我们选择它开始的 x 元素的另一个出现时，它就加 1。

n 表示数据流的长度，“E”是平均符号。

以前面的数据流为例，假设我们在数据流的第 13 位选择了“a”，在第 8 位选择了“d”，在第 3 位选择了“c”。我们没有选择“b”。

像这样选择，我们有：

AMS算法的估计是：

这非常接近（59）之前计算的二阶矩的真实值。

现在专注于我的代码，我已经编写了这个函数来计算“真实”第二时刻，通过向量（1d 数组）和一个 for 模拟数据流：

以及计算二阶矩估计值的 AMS 函数：

问题是，当我尝试计算一个小玩具问题（如上面的问题）的价​​值时，这些值有些正确，但是当我尝试将向量扩展到 10000 个元素时，这些值是真的 Second Moment和尊重，是完全不同的。

我认为问题与我生成数据流的方式以及我决定选择 X.element 的方式有关。

那是：

用于生成随机向量\数据流

和

对于 X.element 选择（在上面的代码中，在 AMS 函数中完成）

对于随机向量\数据流的生成，一个想法可能是由于向量缺乏“可变性”（string.ascii_letters 只得到了 52 个元素）。

你如何找到数组中最长的不同（！）元素行？

我们有一个矩阵 我们的任务是在这个矩阵中找到一行，其中最长的一行是不同的元素

例如 0 1 2 3 4 1 2 3 应该计数 0 1 2 3 4 = 5 个元素

您好我一直在尝试实现一个应用程序，它将 iOS 设备中录制的音频流式传输到 Web 服务。我希望音频能够在现场直播。为此，我使用音频队列实现。我能够录制音频，调用了 AudioInputCallBack 但未触发发送数据的请求。

请帮助我。我在这里发布示例代码

我有一个连续的数据流。我想实时对数据进行少量处理（主要是压缩，最后滚动一些数据，无论需要做什么），然后存储数据。估计没问题。HDF5 文件格式应该很棒！OOC数据，没问题。Pytables。

现在麻烦了。有时，作为一个完全独立的过程以便仍在收集数据，我想执行一个涉及数据的耗时计算（订单分钟）。这涉及读取我正在编写的同一个文件。

人们如何做到这一点？

当然，阅读您当前正在编写的文件应该是具有挑战性的，但它似乎在过去已经出现了足够多的情况，以至于人们已经考虑了某种巧妙的解决方案——或者至少是一种自然的解决方法。

部分解决方案：

1. 似乎 HDF5-1.10.0 具有 SWMR 能力 - 单写，多读。这似乎正是我想要的。我找不到这个最新版本的 python 包装器，或者如果它存在，我无法让 Python 与正确版本的 hdf5 对话。这里的任何提示都会受到欢迎。我正在使用 Conda 包管理器。

2. 我可以想象写入缓冲区，该缓冲区偶尔会被刷新并添加到大型数据库中。如何确保在执行此操作时不会丢失经过的数据？

这似乎也可能在计算上很昂贵，但也许无法解决这个问题。

3. 收集更少的数据。这有什么好玩的？

我正在开发 Unity3D 中的一个项目，我需要将大量数据从客户端计算机发送到主/服务器计算机。

每台客户端计算机都连接有一个 Kinect 传感器。一些Kinect 数据将以某种方式传送到本地化的主计算机。

我的问题是，最好的方法是什么？我目前在 Unity3D 中的 C# 中使用 RPC 网络协议。我基本上有一个客户端 Unity 在客户端计算机上运行，​​从 kinect 获取数据，将其转换为字节并通过 LAN 将其发送到我的服务器（由另一个 Unity 程序接收）。

但是，仅使用一个客户端会使用 10Mb/s 的下载/上传速度，并且在大约 30 秒的流式传输之后，我的网络似乎陷入了困境，然后拒绝发送更多数据，直到我再次重新启动客户端。

我对网络程序不太了解。但我只是想知道是否有更好的方法可以使用？

笔记：

• 所有客户端和主计算机实际上都在同一个房间里（所以一切都是本地的）。

• 根据我的计算，每个客户端需要大约 10Mb/s 的速度。很可能会有大约 6 个客户。意味着总流为 60Mb/s。如果我沿着网络路线走，这应该不是问题吗？（因为它都是本地的）。

• 流不一定必须出现在 Unity3D 中，只要我可以在 Master 端将数据实际输入 Unity 即可。

• 数据本身大约每秒发送约 30 次（考虑到“10Mb/s”）

谢谢。

- - 更新 - -

我在做什么？

这个想法是能够将所有客户端（连接了 Kinects）的 3D 深度数据流式传输到主服务器。主人随后将处理所有这些数据，并构建所有 Kinect 所面对的房间中心的 3D 表示（使用点云）。

• 这是实时的（或尽可能实时 - 鉴于情况）。

• 我确实在使用有线局域网（全部通过具有千兆以太网的新路由器连接） - 全部本地化，彼此相距 10 英尺。

• 主计算机是 2.3 GHz Intel Core i7，因此它应该能够接收 10Mbs 的流。

• 据我所知，我之前提到的“陷入困境”的问题可能归结于 Unity 的 RPC 系统？！：/

• 我很想编写一个小的 Windows 程序，它将 Kinect 数据流式传输到主 IP - 并让 Unity 来获取它（不知何故 - 我不知道如何实现 - 它看起来更合乎逻辑，对吗？）

谢谢。

我希望将数据流式传输到yaws我的彗星应用程序，我已经阅读并努力理解它，但是来自 yaws 的示例对我来说似乎有点复杂（我是 Erlang 的新手）。我就是摸不着头脑...

这是来自 yaws 的示例（我稍作修改）：

我需要将上面的脚本转换为可以与以下内容结合使用的脚本。

Whereparse_data(FieldValues, [], [], [], [], [])返回条目的 JSON 字符串。 结合此脚本应该不断检查数据库中的新条目，如果有，它应该像彗星一样获取。

谢谢你们，愿你们都去天堂！