node.js-stream 相关问题



Laravel9 response()->stream() 使用 fwrite() 得到空结果

我需要将大量数据导出为 CSV 字符串。 所以我尝试将 fopen('php://stdout', w) 与 fwrite($file, $data) 一起使用。 但 Laravel response()->stream() 不会返回任何内容,也不会出现错误。 我...


npm v9.4.0 不支持 Node.js v14.15.0

npm 的接受版本是什么(Node.js v14.15.0)。给我以下错误: npm WARN cli npm v9.4.0 不支持 Node.js v14。 15.0。您可能应该升级到 npm WARN cli 新版本没有...


“Next.js 应用程序需要 Node.js 版本 >= v18.17.0,但在 Node.js 16.20.2 中遇到错误 - 如何解决?”

当我使用 cli 创建下一个 js 应用程序时,然后我输入 npm 运行开发 我收到这个错误。 您正在使用 Node.js 16.20.2。对于 Next.js,需要 Node.js 版本 >= v18.17.0。 但我的node版本是v...


我在运行node.js 文件时遇到错误

我是 Node.js 新手,我正在尝试通过 Node.js 运行我的测试文件。我只是输入 node 。 ut63.js 但它显示以下错误: 错误:找不到模块 'C:\Users\User11\Desktop\Co...


无法使用 win32-x64 运行时 (Strapi) 加载“sharp”模块

我曾经使用本地安装的 Node.js v16.x 来运行 Strapi,效果很好。 但最近由于另一个项目不得不更新到 Node.js v18.x,所以我安装了 NVM 来管理多个 Node.js


安装node npm 不断出现错误消息

我正在安装这些 npm 软件包: npm 我表达 body-parser bcrypt cors dotenv gridfs-stream multer multer-gridfs-storage 头盔 morgan jsonwebtoken mongoose 但是,当...


如何替换 Node.js 中已弃用的 crypto.createCipher?

我正在使用以下函数来加密/解密 Node.js 中的字符串: var crypto = require('crypto'); var 算法 = 'aes-256-ctr'; 函数加密(文本){ var cipher = crypto.createCipher(


来自具有阻塞操作的迭代器的 Akka 源代码

Source.fromIterator 上的 Akka 文档 (https://doc.akka.io/docs/akka/current/stream/operators/Source/fromIterator.html) 说: 如果迭代器执行阻塞操作,请确保 r...


Node.JS 在运行时切换用户

以 root 身份运行的 Node.JS 程序是否可以在运行时降级其权限?这将是它首先要做的事情之一,目的当然是限制 po...


如何解决奇数编号的 Node.js 版本不会进入 LTS 状态且不应用于生产节点:16120 UnhandledPromiseRejectionWarning

我尝试创建一个新的角度应用程序ng新应用程序,但出现此错误 检测到 Node.js 版本 v11.0.0。 奇数编号的 Node.js 版本不会进入 LTS 状态,并且不应用于产品...


在 Node.js 应用程序中调用 notFoundHandler() 后,GraphQL 路径无法访问

我在将 GraphQL 集成到 Node.js 应用程序时遇到问题。最初一切正常,但添加 notFoundHandler() 后,位于 localhost:3000/graphql 的 GraphQL 端点不再存在...


无法在 centos 7 上下载存储库“pgdg-common”的元数据

当我尝试在 CentOS Stream 8 上安装或更新软件包时,会出现此错误 [root@e2e-101-138 \~\]# sudo yum update RHEL / Rocky 8 的 PostgreSQL 通用 RPM - x86_64 ...


Node.js Solana websocket 程序订阅返回太多事件

我有一个使用Solana的JSON RPC websocket方法programSubscribe的node.js文件。我遇到的问题是我收到了一年前发生的事件。我如何使用过滤器来获得...


如何在Dijkstra中一行使用Java Stream

我正在尝试实现 Dijkstra 并且也在学习流。我无法使用流实现以下代码片段。我正在尝试使用流来迭代地图,过滤关键基础...


使用 Java 8 Stream API 从对象列表中收集列表

我有一堂这样的课 公共类示例{ 私人列表 ID; 公共 getIds() { 返回这个.ids; } } 如果我有一个此类的对象列表,如下所示 ...


node.js + wordpress 返回帖子数据

我正在开发一个node.js服务器来获取外部api数据,然后使用我的客户端从我的节点服务器获取数据,而不是调用api站点。 我正在使用express,axios,...


在 Google Cloud Build 期间在 Google Cloud SQL 上运行 node.js 数据库迁移

我想在 Cloud Build 过程中运行用 node.js 编写的数据库迁移。 目前,正在执行数据库迁移命令,但 Cloud Build 进程似乎正在执行...


删除 Firestore 到 BigQuery 扩展的更改日志中的旧行

我正在使用 Firebase Extension Stream Firestore to BigQuery 将数据导出到 BQ。 它工作得很好,我已经使用它好几年了。 然而,桌子的大小正在开始......


Node.js 服务器上的 React Native Socket.IO 未连接

我正在构建一个React Native Expo应用程序,需要使用socket.io进行实时通信。我正在本地主机上运行 Node.js 服务器。 这是我的代码 React Native - home.js 从 & 导入 { io }


将 Node.js 后端连接到 AWS RDS MySQL 数据库时出现问题

你好吗? 我在将 Node.js 后端连接到 AWS RDS MySQL 数据库时遇到问题。我从 Digital Ocean 迁移到 AWS,它在 Digital Ocean 中运行得很好。然而,mig之后...


迁移到 CentOS Stream 9

据我们所知,CentOS 7 将于 6 月 24 日停产。我目前在我的网络中安装了 7.9 核心,但是由于 EOL 和其他安全风险,我想知道我的最佳选择是什么。


Java Stream 中多个对象属性的累积和

我有一个按月年字符串属性排序的对象列表。 我的对象类定义如下: 公共类 Obj { 字符串年份; 会员数量长; 长期非会员人数; 双


多个对象属性Stream的累加和

我有一个按月年字符串属性排序的对象列表。 我的对象类定义看起来像 公共类Obj{ 字符串年份; 会员数量长; 长期非会员人数; 双


Java 和 Xerces:找不到属性 XMLConstants.ACCESS_EXTERNAL_DTD

我在这个博客上查找了类似的帖子,但找不到我的问题的答案,所以我决定寻求帮助。 我用 Java 编写了这个简单的函数: public void open(InputStream stream) 抛出


提高Java/Stream/filter的响应时间

我正在使用流(filter/anyMatch)对两个对象列表进行比较。两个列表的大小最多可达一百万个对象。 我用下面的代码进行了测试。通常t的大小...


使用 Node.JS 调用 AWSglue 的 lambda 函数没有 console.log 的原因?

我正在尝试使用 lambda 函数和 node.js 启动 AWS 粘合作业。我可以很好地测试 lambda 函数,但在脚本运行完毕后似乎没有任何反应。我添加了一些


需要使用 Node.js 压缩整个目录

我需要使用 Node.js 压缩整个目录。我目前正在使用node-zip,每次该进程运行时都会生成一个无效的ZIP 文件(正如您可以从此Github问题中看到的那样)。 有没有...


需要能够打印在node.js无头浏览器中创建的数据

如何解决问题才能打印出任何数据,例如。在运行无头浏览器的 node.js 中创建的即时字符串、变量等作为 console.log('Text') 将不起作用。 例如是 常量...


node.js https 示例,错误,连接到本地主机的未知 SSL 协议错误

我使用这些链接中的简单示例: a 链接[a 如何在 Node.js 中创建 HTTPS 服务器?] a link[a 如何创建 https 服务器? docs.nodejitsu.com] 但我收到类似的错误 卷曲:(35) 未知 SSL


在Java中将流转换为字符串

我想将 Map<> 的流转换为字符串,并将其附加到文本区域。我尝试了一些方法,最后一个使用 StringBuilder,但它们不起作用。 公开 我想将 Map<> 的流转换为字符串,并将其附加到文本区域。我尝试了一些方法,最后一个使用 StringBuilder,但它们不起作用。 public <K, V extends Comparable<? super V>> String sortByAscendentValue(Map<K, V> map, int maxSize) { StringBuilder sBuilder = new StringBuilder(); Stream<Map.Entry<K,V>> sorted = map.entrySet().stream() .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())); BufferedReader br = new BufferedReader(new InputStreamReader((InputStream) sorted)); String read; try { while ((read=br.readLine()) != null) { //System.out.println(read); sBuilder.append(read); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } sorted.limit(maxSize).forEach(System.out::println); return sBuilder.toString(); } 您可以将条目收集到一个String中,如下所示: String sorted = map.entrySet().stream() .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())) .map(e-> e.getKey().toString() + "=" + e.getValue().toString()) .collect(Collectors.joining (",")); 考虑对 @Eran 的代码进行轻微更改,因为 HashMap.Entry.toString() 已经通过 = 为您加入了: String sorted = map.entrySet().stream() .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())) .map(Objects::toString) .collect(Collectors.joining(",")); 这很容易做到,您可以使用 Steams API 来做到这一点。首先,将映射中的每个条目映射到单个字符串 - 键和值的连接字符串。一旦你有了这个,你就可以简单地使用 reduce() 方法或 collect() 方法来做到这一点。 使用“reduce()”方法的代码片段将如下所示: Map<String, String> map = new HashMap<>(); map.put("sam1", "sam1"); map.put("sam2", "sam2"); String concatString = map.entrySet() .stream() .map(element-> element.getKey().toString() + " : " + element.getValue().toString()) .reduce("", (str1,str2) -> str1 + " , " + str2).substring(3); System.out.println(concatString); 这将为您提供以下输出: sam2 : sam2 , sam1 : sam1 您还可以使用 collect()' method instead ofreduce()` 方法。它看起来像这样: String concatString = map.entrySet() .stream() .map(element-> element.getKey().toString() + " : " + element.getValue().toString()) .collect(Collectors.reducing("", (str1,str2) -> str1 + " , " + str2)).substring(3); 两种方法给出相同的输出。


HttpMediaTypeNotSupportedException:从 AWS Lambda 运行 SpringBoot REST 应用程序时不支持内容类型“application/octet-stream”

我正在尝试在 AWS Lambda 中运行 Spring Boot 应用程序(例如,各种示例使用与 https://www.baeldung.com/spring-boot-aws-lambda 基本相同的方法 - 只需复制代码和...


如何在 C++/WinRT (WinUI3) 中将图像从内存读取到 ImageSource?

[1] 我想在 XAML 中显示 Image 控件的图像,但该图像来自字节数组。 我应该怎么办?图像格式可以是JPG、BMP或PNG之一。 [1] 我想在 XAML 中显示 Image 控件的图像,但该图像来自字节数组。 我该怎么办?图像格式可以是 JPG、BMP 或 PNG 之一。 <Image x:Name="img"/> void MainWindow::myButton_Click(IInspectable const&, RoutedEventArgs const&) { unsigned long long size; // iamge data size const unsigned char* buf; // image data img().Source(???); // what should I do? } [2] 我尝试了InMemoryRandomAccessStream,但没有成功。 我知道在C#中使用MemoryStream很方便,但是如何在C++中实现它? 另一个问题是这个方法是否也适用于JPG和PNG格式的图像? void MainWindow::myButton_Click(IInspectable const&, RoutedEventArgs const&) { unsigned long long size; // iamge data size const unsigned char* buf; // image data winrt::Microsoft::UI::Xaml::Media::Imaging::BitmapImage bmp; winrt::Windows::Storage::Streams::InMemoryRandomAccessStream stream; // How to read data from stream? bmp.SetSource(stream); img().Source(bmp); } [3] 现在功能已经实现了,但是还有两个问题 IAsyncAction MainWindow::myButton_Click(IInspectable const&, RoutedEventArgs const&) { unsigned long long size; // iamge data size const unsigned char* buf; // image data winrt::Microsoft::UI::Xaml::Media::Imaging::BitmapImage bmp; winrt::Windows::Storage::Streams::InMemoryRandomAccessStream stream; winrt::Windows::Storage::Streams::DataWriter dw(st.GetOutputStreamAt(0ULL)); dw.WriteBytes({ buf, size }); // This is very inefficient! co_await dw.StoreAsync(); dw.Close(); bmp.SetSource(stream); img().Source(bmp); stream.Close(); } 首先,我发现DataWriter::WriteBytes()确实是在复制数据。但我认为ImageSource只需要从我的buf中读取即可,不需要在读取之前将整个图像完全复制到流中。也许是类似MemoryView的东西,我这样想是不是错了? 其次,DataWriter和InMemoryRandomAccessStream的Close()应该在哪里调用? BitmapImage需要释放内存吗?这里有一个异步函数,我不知道应该写在哪里 [4] 根据IInspectable,我尝试了SHCreatMemStream并搜索了大量信息以提出另一个解决方案。目前的问题是,与方法[3]同样可行,但仍然会出现内存分配问题。 #include "Shlwapi.h" #include "shcore.h" #pragma comment(lib, "shlwapi.lib") void MainWindow::myButton_Click(IInspectable const&, RoutedEventArgs const&) { unsigned long long size; // iamge data size const unsigned char* buf; // image data winrt::Microsoft::UI::Xaml::Media::Imaging::BitmapImage bmp; IStream* stream{ SHCreateMemStream(buf, size) }; // Copying takes a lot of time static const GUID guidIRandomAccessStream = { 0x905a0fe1, 0xbc53, 0x11df, { 0x8c, 0x49, 0x00, 0x1e, 0x4f, 0xc6, 0x86, 0xda } }; winrt::Windows::Storage::Streams::IRandomAccessStream pRas{ }; CreateRandomAccessStreamOverStream(stream, BSOS_OPTIONS::BSOS_DEFAULT, guidIRandomAccessStream, (void**)&pRas); bmp.SetSource(stream); img().Source(bmp); } 通过性能测试,发现CreateRandomAccessStreamOverStream的时间是一致的,但是SHCreateMemStream消耗的时间与图像大小成正比。可以得出,SHCreateMemStream中创建流的过程也涉及到内存的复制。 我对Windows编程中的Stream不是特别熟悉。创建流的过程一定会涉及到内存复制吗?从内存加载图像可以避免额外的开销吗?还有没有类似MemoryStreamView的结构来替代吗? 还有一个问题,我知道新的图像肯定需要内存存储。 BitmapImage设置Stream为Source会接管Stream占用的内存吗? Image控件设置BitmapImage作为Source会接管BitmapImage占用的内存吗? 如果是这样的话,我可以接受Stream分配新的内存,否则仍然是一个效率问题。 谢谢!!!!!!! 使用Stream已经彻底解决了这个问题。如前四期所述。 至于附加问题: ★1 使用 CreatStreamOnHGlobal 而不是 SHCreatMemStream。 因为SHCreatMemStream在调用过程中会对传入的内存块参数进行另一次内存复制。 CreatStreamOnHGlobal 创建流后不执行内存复制。您可以先通过GlobalAlloc分配内存,写入所需的图像数据,然后调用CreatStreamOnHGlobal,无需任何时间开销。另外,可以将CreatStreamOnHGlobal的第二个参数设置为true,自动释放GlobalAlloc分配的内存。 通过进程内存监控,我发现对于同一个程序,使用CreatStreamOnHGlobal的速度是SHCreatMemStream的两倍,并且不会导致内存泄漏。 ★2 创建的Stream需要调用Release方法减少一个引用。 IRandomAccessStream作为局部变量,会自动析构,无需主动释放。 并且BitmapImage还管理一部分引用,这些引用在离开作用域后被释放。 通过测试COM对象上Release方法的返回值,发现整个程序结束后引用计数又回到了0


无服务器框架版本 2 是否支持 Node.js 版本 18 或更高版本

我们收到了来自 AWS 的 lambda 通知:AWS 将在 6 月 24 日之后终止对 Node.js 版本 16 或更低版本的支持生命周期 (EOL)。目前我们的无服务器框架版本:“2”


在 Vercel 上部署 Node.js 应用程序时出现配置包问题 - “配置属性未定义”错误

我使用 Node.js 中的配置包来组织我的所有环境变量,它在我的本地环境中完美运行。但是,当我将应用程序部署到 Vercel 时,我遇到了以下情况...


AWS 使用 Cloudformation 为 Kinesis Firehose 放置订阅筛选器 - 检查给定的 Firehose 流是否处于活动状态

按照本指南创建 Kinesis Firehose Stream。 我已按照指南进行操作,当我开始创建订阅过滤器(步骤 12)时,我在尝试发送到 S3 时遇到此错误: 一个


从Node.js服务器中的Java Android应用程序接收JSON,并将其插入到Mongodb数据库

所以我尝试使用 Node.js 服务器将数据从 Java Andoid 应用程序插入到 Mongodb 数据库。但是我的 JSON 对象是空的(正如我所想的)并且读取值是“未定义”。我正在使用 mongodb


docker中npm start启动node应用程序的问题

我阅读了一些 Docker 和 Node.js 最佳实践文章,例如https://github.com/nodejs/docker-node/blob/main/docs/BestPractices.md 或使用


VSCode 终端未在 Linux (POP_OS 20.10) 中打开

有什么办法可以解决这个问题 VSCode 详细信息 版本:1.55.2 提交:3c4e3df9e89829dce27b7b5c24508306b151f30d 日期:2021-04-13T09:37:02.931Z 电子:11.3.0 铬:87.0.4280.141 Node.js:12.1...


Node.js/fastify 出现错误,不支持的媒体类型:application/x-www-form-urlencoded

考虑: 文件index.js fastify.get("/paynow", (请求, 回复) => { 让数据= { TXN_AMOUNT: '10', // 请求金额 ORDER_ID: 'ORDER_123455', // 任何唯一的订单 ID CUST_ID:'


mongodb和nodejs中的promise待处理错误

我已经编写了node.js代码,用于使用mongodb数据库获取一些数字。这是我的代码 MongoClient.connect('mongodb://localhost:27017/mongomart', 函数(err, db) { 断言....


Node.js/fFastify 出现错误:“不支持的媒体类型:application/x-www-form-urlencoded”

考虑: 文件index.js fastify.get("/paynow", (请求, 回复) => { 让数据= { TXN_AMOUNT: '10', // 请求金额 ORDER_ID: 'ORDER_123455', // 任何唯一的订单 ID 库斯...


使用节点和护照未经谷歌oauth登录身份验证500

我正在使用passport-google-oauth 运行node.js。从我的 package.json 中: "passport-google-oauth": "~1.0.0", 我遵循了本教程:https://scotch.io/tutorials/easy-node-authentication-google 在...


ReferenceError:文档未定义(javascript)

在这里输入图片描述为什么安装完node.js后,运行各种javascript命令的代码后会出现这样的错误,看来不是因为代码错误而是因为n...


期望变量为空或布尔值

我正在使用 Jest 为 Node.js 后端开发一些测试,我需要检查来自第三方的一些值。在某些情况下,这些值可以是布尔值或空值。 现在...


将“null”值传递给node.js中的MySQL数据库

我正在尝试将数据从 Webscraper 传递到 MySQL 数据库。我有很多变量需要一次输入数据库,下面是我正在使用的代码片段。 (哪里...


如何在不使用超时的情况下处理永远不会解决或拒绝的 Promise

我在 Node.js 中使用 TypeScript。我已将代码简化为以下内容: 异步函数 runPromise(promise: Promise) { 等待承诺 console.log('完成') } 无效 runPromi...


Heroku 上的部署失败:Vue-CLI 构建错误

我在 Heroku 上部署 Node.js 应用程序(其中包括 Vue.js 前端)时遇到了持续存在的问题。尽管多次尝试和不同的配置,我的构建始终如一......


使用 Nodejs18 运行时将 `@aws-sdk/client-bedrock-runtime` 导入 AWS Lambda 函数

我正在尝试使用 NodeJs18 运行时将 @aws-sdk/client-bedrock-runtime 导入到 AWS Lambda 函数中。 该软件包应该可用,因为根据 AWS 文档,“对于 Node.js 版本......


ReferenceError:找不到变量:require

我在将node_modules加载到我的网页之一时遇到问题。我安装了 npm(node.js),并且想使用 require() 函数在我的网站上初始化 Firebase,但我不知道为什么,但它抛出了 Reference ...


© www.soinside.com 2019 - 2024. All rights reserved.