stream

    0热度

    1回答

    我有一个用作事件记录器的Spring Boot应用程序。每个客户端通过REST api发送不同的事件,然后保存在数据库中。但除了简单事件之外,我还需要客户将其执行日志发送到Spring Boot。 现在,在客户端执行完成后上传日志很容易,并且有很多示例。我需要的是在客户端正在执行时逐行传输日志,而不是等到客户端完成。 我花了很长时间搜索一个可能的答案,我找不到任何符合我需要的东西。任何建议如何使用

    2热度

    2回答

    我想流的数据收集到多个文件与下面的代码: for (var key in data) { // skip if collection length is 0 if (data[key].length > 0) { // Use the key and jobId to open file for appending let filePath = folder

    0热度

    1回答

    我需要用Swagger使用NodeJS编写上传代码。要求是创建两个调整大小的文件并将它们发送到AWS S3。我可以这样做: 将传入的文件保存在磁盘上。 打开原始文件,调整大小(版本1)并将其保存在磁盘上。 再次打开原始文件,调整其大小(版本2)并将其保存在 磁盘上。 从VERSION1创建流1 从版本2 创建流2发送两个流,以S3 删除残留文件 我所寻求的是建立从输入流调整大小的文件飞行并将它们发

    1热度

    1回答

    我正在制作一个应用程序,记录用户在说什么,并将其保存到文件中。为了从麦克风获得声音,我正在使用node-microphone包。我的应用程序目前能够从麦克风获得声音。但是,当我尝试将流写入音频文件并播放它时,出现以下错误。 Windows Media Player无法播放该文件。播放器可能不支持文件类型 ,或者可能不支持用于压缩文件的编解码器 。 有谁知道如何将音频写入节点中的文件? var fs

    7热度

    1回答

    我有两个要合并的数据流。问题是一个数据流的频率比另一个高得多,并且有时候一个数据流根本没有接收到事件。是否有可能使用来自一个流的最后一个事件并将其与每个即将到来的事件的另一个流加入? 我发现的唯一解决方案是使用连接函数,但您必须指定一个公共窗口,您可以在其中应用连接函数。这是未达到的窗口,当一个流没有收到任何事件。 是否有可能将连接函数应用于来自任何一个流或另一个流的每个事件,并维护上次使用事件的

    2热度

    1回答

    我想要一个find函数用于大小有界类型的流,类似于列表和查找函数。 total find : MaxBound a => (a -> Bool) -> Stream a -> Maybe a 的挑战是它,使其: 是总 消耗不超过 恒定 log_2Ñ空间,其中N是编码最大a所需的比特的数量。 时间不超过一分钟,以检查在编译时 没有征收成本运行 通常对于流的总能找得到实现听起来荒谬。流是无限的,

    2热度

    1回答

    我正在接收和使用原始正文的http post请求,并且正在尝试将http正文读入String中。 我使用dotnet web命令生成的基本Hello World网络项目。按照documentation: In the .NET Framework 4 and earlier versions, you have to use methods such as BeginRead and EndRea

    0热度

    1回答

    使用滑块旋转的Facebook馈送时出现错误。当我在本地使用它时,它完美地工作,但当我在普通的URL中启动它时,出现此错误:Revolution Slider Error: Failed to load Stream。 我是否必须改变我的.htaccess或php.ini中的内容? 感谢

    0热度

    1回答

    我正在尝试使用python将来自Raspberry Pi的视频流传输到我的机器。因此,我需要将套接字连接到服务器。 (流视频直接在192.168.0.6:8081从RPI执行这些之前) 在我的电脑上我执行此代码: import numpy as np import cv2 import socket class VideoStreamingTest(object): def

    1热度

    1回答

    我需要创建base64字符串,我需要发送到第三方API。我有流和缓冲区。表单流我能够创建一个图像,所以没有办法破坏流。这里有两个变量: var newJpeg = new Buffer(newData, "binary"); var fs = require('fs'); let Duplex = require('stream').Duplex; let _updatedFileStr