问题标签 [nodejs-stream]

不同的用户试图通过大量的数据操作来访问不同的应用程序路由。由于内部服务器错误，其中一个请求失败了，我的整个应用程序都崩溃了。这就是其他请求失败的原因，因为构建已经崩溃。有没有办法处理这种情况？

我正在使用 azure 函数使用 jimp 生成缩略图。我面临的挑战是 azure 容器上的内容类型最终是 application/octet-stream 而不是 image/jpeg。如何解决这个问题？

这是代码：

问题：

使用request模块下载的文件，写入文件系统与使用浏览器直接下载的文件不同

我正在获取位于的字体文件https://assets.ajio.com/static/assets/ec86819f634b9e9979b83bae65b170dd.woff。有以下3种情况。

情况1

现在，当网站通常从其源代码运行此 URL 时，以下是响应 [在开发人员工具中检查]

d09GRgABAAAAAPqMABAAAACNCgAAQAyAAAAAAAAAAAAAAAAAAAAAAAAAAAAABCQVN....

当我使用我的 nodejs 脚本获取它时，我得到了响应

wOFF....??....4(...2....

以上是我在浏览器的开发者工具网络选项卡中看到的响应。

案例2

但是，当我在 Postman 中同时运行 url 即原始和我自己的 url 时http://<host>/_oe/https://assets.ajio.com/static/assets/ec86819f634b9e9979b83bae65b170dd.woff，我得到了相同的响应。

案例3

然后再次复制并粘贴https://assets.ajio.com/static/assets/ec86819f634b9e9979b83bae65b170dd.woff到浏览器中时，下载的文件看起来像

774f 4646 0001 0000 0000 c7f4 000b 0000 0000 c7a8 0001 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 4f53 2f32

并且使用我的 nodejs 脚本编写的文件看起来像

774f 4646 0001 0000 0000 efbf bdef bfbd 000b 0000 0000 c7a8 0001 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000

两者又不同了。

问题

我的问题是，任何人都可以解释这里发生了什么，我做错了什么，以及我可以做些什么来获得具有正确编码的正确字体文件，以便在前端正确使用它。

Nodejs 脚本：这是我的 nodejs 代码

更新

我什至在写文件时使用了“二进制”选项，即

现在在控制台上我得到所需格式的数据 d09GRgABAAAAAP39AAs...

但仍然与我从原始网站获得的不同，即 d09GRgABAAAAAPqMABMAAAACNC...

我有一个配置是这样的。

使用 expressjs 在 Nodejs 上运行的客户端应用程序服务器。API 服务器在 Nodejs 上使用 expressJs 运行，我正在使用 postgresql 数据库。

当我的客户端从 api server 请求数据时，api server 抛出错误

我猜它的原因是，api 正试图用一个非常大的 Json 对象数组来响应客户端，它是从数据库中获取的。

现在我的问题是，如何在 http 响应中发送如此大的 Json 对象？如果发送成功，我该如何在客户端处理它？

我遇到了 JSONStream 模块。但是，我找不到一个可以在我的场景中选择工具的好例子。

我是 HTML 开发人员，最近开始学习 Node.js，因为我想成为后端开发人员，

由于我是后端技术和 javascript 的新手，所以我只想问一些基本程序，如奇偶、模式问题或其他类似类型的问题将有助于开发我的逻辑，或者我应该直接开始从事项目工作并做项目我的逻辑会自动改进

我正在使用npm install socket.io-stream 我socket.io-stream在我的角度组件上实现，如下所示：

我只想像这样创建一个双工流：

运行时出现此错误ng build：

我不明白，因为在我的 server.js 上它似乎工作..

我尝试运行该命令npm install stream，但没有错误ng build。但是当我启动我的应用程序时，我的浏览器控制台中出现了一个新错误：

谢谢你的帮助

我正在寻找一个具有并发性的大规模并行处理系统，它可以为每 500 毫秒超过一百万个物联网设备提供无缝数据摄取解决方案。

寻找开源的、高度可扩展的、不同协议的丰富库，支持 ESB，并且可以无故障地管理多线程。

是 Apache Beam、Apache Nifi 还是 Apache Camel 或 WSO2 更好的选择。

所以，我使用 Node 的child_process模块来生成一个弹性搜索的实例。我需要检查服务何时启动并resolve()承诺何时启动。这就是我现在的做法：

这是最好的方法吗？（可能不是）如果不是，我应该怎么做？

我使用请求模块下载包含 .csv 文件的 zip 文件，然后使用管道通过解压缩和拆分模块读取内容，然后使用 mongoose-object-stream 模块解析并将结果写入 mongodb。
我的代码：

当流结束并且所有记录都存储在数据库中时，我想做一些事情。

我尝试添加到管道 .on('finish', function(){process.exit()}) 或 .on('end', function(){process.exit()}) 但节点继续运行。

关于stream.Transform的transform函数：
可以吗，因为它不会破坏诸如背压机制之类的东西，
并且假设我不关心顺序，在调用push（）之前调用callback（）以便我可以同时异步处理超过 1 个块吗？

具体来说，我想发出异步 http 请求。我有一个“url 流”，我想 push() 处理后的结果以供进一步处理/存储。

如果我在调用 callback() 之前等待请求完成，我每次只会运行 1 个请求。但是，如果我在请求播出时调用回调：

我可以同时处理许多请求。

该代码似乎有效，但我想知道我是否在滥用 stream.Transform 以及我是否应该为这种管道完全使用其他东西。