问题标签 [nodejs-stream]

我厌倦了使用 mongodb 在节点 js 中实现 crud 操作。我在 mongodb 中有 5000 个数据。在数据中我有很多图像。第一次我尝试使用获取数据来显示所有 5000 个数据。但是它显示 50 秒的延迟来显示数据.如何毫不拖延地显示数据。给我解决方案

我在节点 js 中实现回调函数。但我对回调函数有疑问。我在节点 js 中尝试了两个函数，一个回调函数和另一个普通函数。两个函数我都试图运行它给定的相同结果。我没有人解释我的代码。

回调函数.js

normal_function.js

它显示结果 hello 和 hai

我了解回调函数但我不了解promise方法和async和await。为什么要在节点js中使用这三个函数。可以给出示例代码的解释。

我尝试了 mongodb 中的 get(selected values) 查询。该查询在 mongodb shell 中运行良好。但我尝试运行节点 js，但它无法显示所有数据。如何修复它。

询问

预期输出：

但我得到了这个输出：

我在节点js中尝试了两个函数（异步函数，普通函数）。普通函数成功返回值。但是异步函数无法返回值。如何修复它

正常功能

index.js

产品.js

异步函数

index.js

产品.js

正常功能

预期输出
hai
hello

异步函数

预期输出
hai
hello

但我得到了输出
[AsyncFunction: sample]

我有多个可以使用令牌访问的 sse 流。我需要保持所有流打开并更新来自流到数据库的响应。我尝试了一个带有 http 模块的流，如链接 https://medium.com/@moinism/using-nodejs-for-uni-directional-event-streaming-sse-c80538e6e82e中所述

它工作正常，但我不知道如何保持多个流打开以及如何区分流？还有可用的 mqtt 流，但我也有同样的问题。

我希望有一个 on data 功能保持打开状态，并通过 ID 来区分各种来源的流式传输。

我正在从 NodeJS 中的流中读取数据，然后使用转换流中的异步函数处理该数据。我希望这个转换流能够并行启动对异步函数的多个调用，但它似乎一次只调用一个。

为了说明我的期望，我在下面编写了一个小程序，该程序从0up生成数字limit - 1，然后将其传递给一个转换流，该转换流以一个小的延迟递增每个数字。如果您运行下面的程序，数字 1 到 20 将按顺序记录，所有这些都有一点延迟。

我本来希望它们以 16 + 4 的块记录，因为默认highWaterMark值为 16。是否有可能获得我想要的行为，如果可以，如何？

即读取流将非常快地生成数据，转换速度较慢，但​​应该接收到高水位线，然后等待其数据已被处理，然后从读取流中请求更多。

我试图将数据插入 mongodb.its 成功插入，但我面临错误的文档插入 mongodb.how 使用 mongodb 中的更新查询更新文档中的键和值的问题。

Json 数据格式

如何使用 mongodb 中的更新查询将关键品牌更新为品牌。

我正在尝试使用 axios 下载外部文件，然后使用 pkgcloud 将其通过管道传输到 openstack 对象存储容器中。上传流似乎在文件完全下载之前结束。

根据控制台输出的事件顺序如下：

我正在使用 AzureblockBlobURL.download()下载图像，但只收到图像的顶部。我可以从 Azure blob 下载到可读流的数量是否有限制？内容长度为 172628 并且存在一个属性highWaterMark: 16384。这些有关系吗？

结果只是图像的顶部。