标签: streaming

实际上，标题说明了一切......我想阅读一个流，但不知道从哪里开始。我在网上搜索了一些文档/教程/任何内容，但没有运气。

任何使用此库的帮助将不胜感激。

[澄清] 我说的是 MMS 流协议库，可以在此处找到。LibMMS 是一个用于解析 mms:// 和 mmsh:// 类型网络流的通用库。这些通常用于通过网络流式传输 Windows Media 视频内容。[/澄清]

我正在尝试找到一种在Qt 4.6 rtsp 流中播放的方法，这是我从 youtube api 获得的，可以以某种方式完成吗？

我正在尝试构建一个直播视频应用程序。我构建了一个rtmp 服务器，它准备好发布和播放流。我需要一种方法来捕获手机的用户相机并将在线流发送到我的 rtmp 服务器。

我在客户端使用 react-native。我发现react-native-camera非常适合处理相机，但我在他们的文档中找不到任何可用于访问相机流的事件/api。

另一个问题是我必须将流发送到 rtmp 服务器的方式。我对这方面一无所知，因此将不胜感激。

我目前正在 Dataproc 上运行 Spark 作业，并且在尝试重新加入组并从 kafka 主题读取数据时遇到错误。我已经做了一些挖掘，但不确定是什么问题。我已经auto.offset.reset设置，earliest所以它应该从最早的可用非提交偏移量中读取，最初我的火花日志看起来像这样：

19/04/29 16:30:30 INFO     
org.apache.kafka.clients.consumer.internals.Fetcher: [Consumer 
clientId=consumer-1, groupId=demo-group] Resetting offset for 
partition demo.topic-11 to offset 5553330.
19/04/29 16:30:30 INFO     
org.apache.kafka.clients.consumer.internals.Fetcher: [Consumer 
clientId=consumer-1, groupId=demo-group] Resetting offset for 
partition demo.topic-2 to offset 5555553.
19/04/29 16:30:30 INFO 
org.apache.kafka.clients.consumer.internals.Fetcher: [Consumer 
clientId=consumer-1, groupId=demo-group] Resetting offset for 
partition demo.topic-3 to offset 5555484.
19/04/29 16:30:30 INFO 
org.apache.kafka.clients.consumer.internals.Fetcher: [Consumer 
clientId=consumer-1, groupId=demo-group] Resetting offset for 
partition demo.topic-4 to offset 5555586.
19/04/29 16:30:30 INFO 
org.apache.kafka.clients.consumer.internals.Fetcher: [Consumer 
clientId=consumer-1, groupId=demo-group] Resetting offset …

我想用 Python 将大数据流写入镶木地板文件。我的数据很大，我无法将它们保存在内存中并一口气写入它们。

我找到了两个可以在 Parquet 文件上读写的 Python 库（Pyarrow、Fastparquet）。这是我使用 Pyarrow 的解决方案，但如果您知道一个可行的解决方案，我很乐意尝试另一个库：

import pandas as pd
import random
import pyarrow as pa
import pyarrow.parquet as pq


def data_generator():
    # This is a simulation for my generator function
    # It is not allowed to change the nature of this function
    options = ['op1', 'op2', 'op3', 'op4']
    while True:
        dd = {'c1': random.randint(1, 10), 'c2': random.choice(options)}
        yield dd


result_file_address = 'example.parquet'
index = 0

try:
    dic_data = next(data_generator())
    df = pd.DataFrame(dic_data, [index])
    table = …

我需要将NDI 流实现到一个网站中，以前是一个 Three.js应用程序。

我发现的只是来自streampunk的 node.js 实现，它不能在 Linux 上运行。

我找不到有关如何实现这一目标的任何信息。有人可以指出我正确的方向吗？

当我从 ASP.NET Core 站点发送大型对象时，我试图尽量减少将大型对象从数据库加载到内存中，因为我OutOfMemoryException偶尔会遇到这种情况。

我想我会流它。现在，根据我的研究，只要您CommandBehavior.SequentialAccess在命令中指定，SQL Server 就支持这一点。我想如果我要流式传输它，我最好尽可能直接流式传输它，所以我几乎将它直接从DataReaderASP.NET MVC流式传输ActionResult。

但是一旦FileStreamResult（隐藏在对 的调用下File()）完成执行，我该如何清理我的阅读器/命令？连接是由 DI 提供的，所以这不是问题，但我在调用GetDocumentStream().

我有一个ActionFilterAttribute在 MVC中注册的子类，因此这为我提供了一个可以调用的入口点ActionFilterAttribute.OnResultExecuted()，但是除了处理清理数据库事务和提交/回滚内容的当前逻辑之外，我完全不知道该放什么（不包括在内，因为它并不真正相关）。

有没有办法在我的DataReader/之后进行清理Command并仍然提供一个Streamto File()？

public class DocumentsController : Controller
{
    private DocumentService documentService;

    public FilesController(DocumentService documentService)
    {
        this.documentService = documentService;
    }

    public IActionResult Stream(Guid id, string contentType = "application/octet-stream") // Defaults to octet-stream when unspecified
    {
        // Simple lookup by Id so that …

我正在尝试构建一个类似 twitch 的应用程序（即多对多实时视频流）。我想使用 WebRTC，因为我想让应用程序可以从所有平台访问（我打算使用 Nativescript 或 PWA 道路）。我的计划是将摄像机从人 A 流式传输到媒体服务器。以多种质量等方式对 WebRTC 流进行转码，并将其发送给所有订阅用户，这些用户也可以播放 WebRTC 流。在理想情况下，将有数千个主播，每个主播都有数千个实时订阅者。

然而，如何做到这一点呢？我需要某种媒体服务器，它负责接收流、转码并转发它。MVP 将只是转发流，而不对其进行转码，但是，将来应该可以添加该优化。

我应该去买 Kurento、Jitsi 之类的东西吗？或者我自己搭建这个服务器可行吗？

这种架构是一个好主意，还是我应该重新考虑一切？我不使用 RTMP 或类似的东西的原因是因为必须投入大量的代码和工作来开发本机应用程序（iOS、Android、任何浏览器）的不同客户端代码。如果我可以使用 WebRTC，这将使客户端代码更容易，并使应用程序可在所有平台上访问。

非常感谢！

我像这样构建了一个 StreamingView：

struct StreamingView: UIViewRepresentable {

    func updateUIView(_ uiView: UIView, context: UIViewRepresentableContext<StreamingView>) {
        //
    }

    func makeUIView(context: UIViewRepresentableContext<StreamingView>) -> UIView {
        let view = UIView()

        let captureSession = AVCaptureSession()
        captureSession.sessionPreset = .photo

        guard let captureDevice = AVCaptureDevice.default(for: .video) else { return view}
        guard let input = try? AVCaptureDeviceInput(device: captureDevice) else { return view}
        captureSession.addInput(input)

        captureSession.startRunning()

        let previewLayer = AVCaptureVideoPreviewLayer(session: captureSession)
        view.layer.addSublayer(previewLayer)
        previewLayer.frame = view.frame

        return view
    } 
}

但它没有用。我怎样才能为流媒体构建一个纯粹的 swiftui 视图？

任何人都可以指导我执行上述操作吗？基本上我想要的：

将单个视频文件流式传输到 RTMP 服务器（在我的情况下为 nginx）的 python 脚本，链接：

rtmp://<ip>/stream/<stream_name>

因此，理想情况下，视频文件将以<Stream_name>. 接下来我希望这个 stream_name 以系列方式生成，例如：stream_1, stream_2,....stream_n. 然后我想要流链接：rtmp://<ip>/stream/<stream_name> 被推送 n 次，但在每次迭代中，流名称从“stream_1”增加到“stream_2”等等。

我目前正在努力寻找合适的库来在 python 中执行此操作。

提前致谢！