nodejs-stream 相关问题



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

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


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

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


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

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


无法将非 ASCII 文件名从 NodeJS 传递到 C++ 模块

我想将文件路径信息从NodeJS发送到我自己的模块(C++使用node-addon-api)。每一方独立工作(即我可以在 NodeJS 和 C++ 中检查/打开文件)。但是,如果想要的话,它就会失败...


VSCode NodeJS 调试器说已附加,但它仅适用于我的 NodeJS 文件之一

我一直在使用附加调试器,直到昨天它都工作正常,但它似乎只适用于我的一个 Nodejs 文件。当我连接调试器时,它说它已连接,然后我可以看到...


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

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


NodeJS 将 Dto 映射到 TypeORM 实体

我有一个运行nestjs框架的nodejs REST API后端,使用typeORM作为我的实体的ORM。 来自 C#/Entity Framework 背景,我非常习惯将 Dtos 映射到数据...


如何访问NodeJS中的FetchError类

NodeJS 18 对 fetch 提供了实验性支持 https://nodejs.org/dist/latest-v18.x/docs/api/globals.html fetch 函数抛出 FetchError 实例,我需要在 try-catch 中使用 insta 对其进行分析...


如何在Dijkstra中一行使用Java Stream

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


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

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


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

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


迁移到 CentOS Stream 9

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


使用 Java 8 Stream 在 Writer 对象中写入字符串值

我试图用以下代码中的流替换普通的 for 循环,该循环在 Writer 对象中写入字符串值: 公共无效保存(){ 尝试 (Writer fileWriter = new FileWriter(file)) {...


内容安全策略不适用于 html

我已经在nodejs中设置了内容安全策略(CSP),并且它正在应用于node。但是,对于根 html 页面,未应用 CSP。如何借助nodejs应用在html上......


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

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


多个对象属性Stream的累加和

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


如何在nodejs中用koa获取“HTTP_REFERER”?

如何从请求对象中获取引用者?变量 this.request.headers['referer'] 为空。


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

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


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

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


在 NodeJs 中并行化

我是 NodeJS/JS 的菜鸟,我对我的代码有疑问。 我正在编写一个函数来从 DynamoDB 表中获取元素,我的第一个版本是这样的 版本1 常量参数 = { 表名:p...


在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 基本相同的方法 - 只需复制代码和...


如何防止在nodejs中通过eval动态加载代码?

有什么办法可以防止在nodejs代码中使用eval和friends吗?它已被至少几个 npm 恶意包使用,我没有理由在我当前的项目中使用它......


如何在 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


使用nodejs和java进行AES-GCM 256加解密

在应用程序中,我希望java前端应该从nodejs获取加密文本并提供固定的SECRET_KEY,它应该能够对其进行解码,反之亦然。任何帮助都是appriced。 我是


根据我的测试,为什么 NodeJS 编码 Varint 比 Rust 快得多?

我使用以下两段代码对 Varint 进行编码,NodeJS 大约需要 900ms,而 Rust 大约需要 2700ms。为什么性能差距这么大? 看来分配内存更省时间-


JavaScript StructuredClone 在 Chrome/Edge 中遇到“非法调用”,但在 NodeJS 中没有遇到问题

在浏览器中运行以下代码: ({ 克隆: StructuredClone }).clone(1); 会得到 Uncaught TypeError: Illegal incalling,在 Chrome/Edge 中测试。 不过在 NodeJS 中运行代码没问题,测试一下...


Docker 容器中的 NodeJS SocketIO 服务器的 ERR_SSL_VERSION_OR_CIPHER_MISMATCH

所以我在docker容器内有一个nodejs socketio服务器。服务器使用与站点相同的 URL(仅在端口 3001 上)以及相同的证书和密钥。但是,我收到此错误,但我不能


针对不同的合并项目使用不同的 MongoDB 集合

我有 2 个 NodeJs 项目,最近将它们合并到一个 NodeJs 服务器中,同时将控制器、服务和 mongoDB 模型保留在两个项目的单独文件夹中。问题是,合并后...


通过libcurl和NodeJS的数据交换问题

我有一个用 C 语言编写的 Windows x64 客户端,需要将文本发送到 NodeJS 服务器,所以我使用 libcurl 来实现这一点,但它不起作用,数据似乎没有到达服务器。 这是客户


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

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


nodejs。从文件读取函数并将其执行到另一个文件中

我创建了 10 个执行抓取操作的 js 脚本 (nodejs)。它们的组成如下: 初始部分:登录 最后一部分:每个脚本的具体操作。 我怎样才能外部化登录专业...


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

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


NodeJS - 子进程 - Exec VS Powershell ISE |为什么结果不同?为什么无法创建 PSCredential?

我的PS脚本: $admin =“测试” $Password = ConvertTo-SecureString "Test12345" -AsPlainText -Force $Credential = [PSCredential]::new( $admin, $Password) if ($Credential -is [系统.


使用 qr-image 生成 Wi-Fi QRCode

npm 模块 qr-image 允许使用 NodeJS 生成 QRCode,如下所示: 从“qr-image”导入 qr; 从 'fs' 导入 fs; qr.image('https://google.com/search?q=hello%20world!', {type:'...


从 Elastic Beanstalk 导出所有环境属性

我已在 AWS Elastic beanstalk 中设置环境属性。我有一个托管在 Linux 上的 Nodejs 应用程序。 我可以通过在


容器化我的 NodeJS 应用程序后找不到我的 pnpm 文件,我该如何解决这个问题?

我是 Docker 和 NodeJS 的新手,我有一个正在尝试容器化的应用程序,但是当我尝试在 docker 环境中加载该应用程序时,它会抛出此错误: 应用程序1 |节点:内部/模块/cjs/loade...


NodeJS 我当前的 Google Cloud 函数名称是什么?

我想使用当前Google Cloud Function的名称来驱动一些逻辑。如何确定我的 Google Cloud Function 名称是什么?


导入 NodeJS 模块中的所有导出

我希望能够访问模块的所有导出,而不必说模块。出口前。 假设我有一个模块: // mymod.js module.exports.foo = function() { 控制台.log(...


HubspotClient - 通过电子邮件 ID 更新联系人不起作用

在 NodeJS 中,我使用的是“@hubspot/api-client”:“^7.1.2”。 使用accessToken创建hubspot客户端如下 const hubSpotClient = new hubspot.Client({ accessToken }); 当我尝试


如何让新的 Angular 17 项目运行?

全新安装 Nodejs (20.10.0) 和 Angular (17.0.8)。新项目(“ng new Default”),没有文件更改。 “ngserve”没有错误,但浏览器控制台显示: main.ts:5 错误


mongodb和nodejs中的promise待处理错误

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


权限monitoring.timeSeries.list被拒绝(或者资源可能不存在)

我正在使用谷歌云项目(Nodejs服务器)。我需要使用“googleapis”从谷歌云收集指标“monitoring.timeSeries.list”。 当我尝试请求 API 时


Nodejs 事件循环?

所以客户端javascript中的异步编程是setTimeOut在浏览器API中运行,因此它不会阻塞javascript单线程。由于我们在 Node 中没有浏览器 API,谁...


Nodemailer 不会发送电子邮件

我有一个与 Nodemailer v. 6.9.3 相关的错误。当我启动 nodeJS localhost 时,会出现以下内容: 错误:连接ECONNREFUSED 127.0.0.1:465 在 TCPConnectWrap.afterConnect [作为未完成](节点:ne...


使用 MSSQL 将 SQL Server 与 Nodejs 连接时出现 SQL Server 错误“[ConnectionError: Login failed for user '****'.]”

我遇到以下错误 [连接错误:用户“****”登录失败。] name: '连接错误', message: '用户\'****\'登录失败。', 代码:'E...


错误:找不到模块“请求承诺”

我正在尝试在 Snowflake Server 中运行我的 NodeJS 代码。 代码没问题,但我收到以下响应: `错误:`找不到模块'请求承诺' 在 Function.Module._resolveFilename (


NodeJS WebSocket 在连接打开后直接关闭

这是我的 websocket 服务器端代码: wss = 新的 WebSocketServer({ 服务器:服务器, 路径:'/聊天' }); console.log('Web Socket 服务器已创建'); wss.on('连接', 函数 (ws, 请求...


redis:net.connect 不是一个函数

我需要将Redis添加到nodejs 但无法顺利执行 使用redis版本,相同的代码,但出现此错误: 我的代码: 从 'redis' 导入 { createClient } 导出常量客户端 =


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