问题标签 [node.js-stream]

我是 phant 新手，使用 mongodb 找不到关于 phant 的合适文档。因为我有很多数据并且会发生内存溢出。最后我陷入了以下错误：

除了有时还会出现以下错误：

这就是为什么我想使用 mongodb 来防止这个错误。我对此进行了搜索，最后找到了 mongodb 的 sparckfun 库： https ://github.com/sparkfun/phant-stream-mongodb

我安装了这个，但什么也没发生，因为数据仍然没有串入 mongo。那么，我将如何将 phant 数据存储到 mongodb 中？

我有一个流可能已经结束，也可能还没有结束。如果它已经结束，我不想永远坐在那里等待end事件。我该如何检查？

我在 Ubuntu 上使用 node.js 制作了 Web 服务器。

我想在播放器连接到网络服务器时显示视频。

索引.html

网络服务器.js

当我运行网络服务器并连接网络服务器时，视频没有在网络浏览器上播放。我只能看到黑匣子和视频控制栏。

但是，当我在 Ubuntu（未运行服务器）上打开 html 文件时，视频播放良好。

连接网络服务器后，如何在网络浏览器上播放视频？

谢谢 ：）

我已将 console.log() 重定向到一个文件(app_stdout.log) 接下来我运行我的程序。正在创建 app_stdout.log 文件。但是如果在程序运行时手动删除日志文件，则不会再次创建 app_stdout.log 文件。为什么？我在这里缺少什么？有什么办法可以从 WriteStream 中捕获错误？

我在 Windows 环境中使用节点。当我使用 fs.unlink(fileName) 时，它似乎可以工作。

在我转到物理驱动器时执行 unlink 语句后，我仍然可以看到该文件。

此时，如果我尝试手动删除文件，则会引发 Access Denied 。或者，如果我尝试创建同名文件，则会收到 Access Denied

但是，仅当我停止执行节点脚本文件时，该文件才会自动从文件系统中删除。

下面是我用来从客户端获取图像并将其上传到 Azure Blob 存储然后删除文件的代码。

这是预期的行为吗？或者我该如何处理

我想可视化实时传感器数据（流数据）。为此，我使用了 node.js、html 和 mysql。mysql 用于存储实时传感器数据，index.html 实现了doPoll app.js 文件的google chart，app.js 文件提供了与mysql 的连接。我能够可视化来自同一系统的数据，但是当我输入 url（公共 IP）Chrome 显示“加载资源失败：net::ERR_CONNECTION_REFUSED”和 firefox 显示“跨源请求被阻止：同源策略不允许读取http://localhost:8686/temperatureData上的远程资源。（原因：CORS 请求失败）。” 我已经从路由器转发了端口 8686。但是我可以使用远程系统的两个浏览器查看 json 格式的数据。app.js 的代码如下：

* */

Index.html 文件的代码如下所示：

我应该怎么做才能提供远程可视化？我想在移动和桌面/笔记本电脑浏览器中提供远程可视化。

I'm attempting to unit test one of my node-js modules which deals heavily in streams. I'm trying to mock a stream (that I will write to), as within my module I have ".on('data/end)" listeners that I would like to trigger. Essentially I want to be able to do something like this:

This executes, but the 'on' event never gets fired after I do the push (and .close() is invalid).

All the guidance I can find on streams uses the 'fs' or 'net' library as a basis for creating a new stream (https://github.com/substack/stream-handbook), or they mock it out with sinon but the mocking gets very lengthy very quicky.

Is there a nice way to provide a dummy stream like this?

我正在将 Grunt 构建任务转换为 Gulp 实现。我正在使用gulp-watch，这是我为运行我的任务而编写的：

问题是，如果更改了许多文件，则任务运行次数过多。我需要找到一种方法来消除输入的抖动，并在新的更改出现时取消任何已启动的任务。

如何取消 Node.JS / Gulp 流？我一直无法找到这方面的好文档。我目前正在尝试.end()，但我不能保证 Gulp 任务（SASS、Autoprefixer 和 CleanCSS）会尊重这一点。

我正在使用 node.js 为 Azure 文件存储创建文件服务。我正在使用azure-storage-node (http://azure.github.io/azure-storage-node/)这个。

我正在尝试从 Azure 文件存储下载文件。下面是我的代码片段

我能够获得数据流。但是我怎样才能在响应中发送流，以便我们可以在 rest 调用中获取它。

我试过readStream.pipe(response);了

我是 node.js 的新手。请帮助我。

更新：

我尝试了以下。

但它抛出以下错误。

的返回数据类型 fileService.createReadStream(shareName, dirPath, fileName);是ChunkStream

更新：

这是我更新的有效代码。

但更频繁地，我遇到了错误。

我们正在尝试使用 Azure 中的 node.js 创建服务以进行下载。我们正在发送 writeStream 作为响应。

更新：

在下载小于 4MB 的文件时，它工作正常。但是当下载超过 4MB 时，它给出了错误。

下面是示例 java 客户端代码。

我们可以将写入流转换为缓冲流吗？如果是这样，我们如何发送响应。或者有没有其他方法可以发送大量数据作为响应。请帮助我。我是 node.js 的新手。