1回答
我有这段nodejs代码，但老实说，我不太明白.pipe是做什么的。
var localoptions = {
url: requestUrl,
milliseconds, default is 2 seconds
};
if (authHeader) {
localoptions.headers = {
"Authorization": authHeader
};
}
request(localoptions)
.on('error', function(e) {
res.end(e);
}).pipe(res);
在这种情况
浏览 0提问于2016-06-23得票数 1
1回答
我正在使用request.get( URL )从url读取一个很大的压缩文件(500MB).File包含一个CSV文件，它的大小相当大。我正在读取响应，并使用fs.createWriteStream(zipFile)将文件流写成压缩文件。在关闭事件的fs.createWriteStream，我已经尝试使用adm压缩文件，我得到了“错误，无效或不支持的压缩格式。没有结束标题找到”和Unzipper npm包，我得到了“无效签名解压缩”。下面是代码 const request = require('superagent');
const fs = require('
浏览 59提问于2021-07-09得票数 1
1回答
我有一个运行python程序的nodejs脚本。我希望在调试会话开始时能够与pdb交互。
我正在使用这个来启动我的进程：
var cp = require('child_process')
var app = cp.spawn('python_app', ['param'])
app.stdout.pipe(process.stdout)
app.stderr.pipe(process.stderr)
process.stdin.pipe(app.stdin)
不幸的是，当调试
浏览 0提问于2016-01-05得票数 1
1回答
我已经编写了一个简单的图像操作服务，它使用来自http响应流的图像上的节点gm。如果我使用nodejs的默认传输编码: chunked，则一切正常。但是，只要我尝试添加content-length实现，nodejs就会挂起响应，或者出现content-length不匹配错误。
下面是相关代码的要点(由于示例的原因，变量已被省略)：
var image = gm(response);
// gm getter used to get origin properties of image
image.identify({bufferStream: true}, functi
浏览 0提问于2013-06-29得票数 0
回答已采纳
我有一个需求，我需要使用wkhtmltopdf使用node js和AWS Lambda将HTML转换为pdf。所以我们对wkhtmltopdf使用nodejs包装器(nodejs-wkhtmltopdf。到目前为止，我们成功地将HTML转换为pdf，但我们面临的挑战是，当我们必须将pdf返回给客户端时。在express中，我们知道我们可以通过管道将流传递给响应对象。 stream = wkhtmtopdf(compiledData).pipe(res) 我的问题是如何在AWS Lambda中做同样的事情。任何帮助都将受到高度的感谢。谢谢,
浏览 24提问于2021-08-02得票数 0
1回答
在NodeJS中，我使用了ExpressJS (其中res是一个可写流)。
const readableStream = someAsyncTask();
readableStream.pipe(res);
readableStrean.on('end', () => {
res.write('a bit more');
res.end();
});
这样做的结果是：
非正常异常错误:结束后写
因此，我假设管道导致可写流关闭。我如何将可读的流输送到输出，然后当该流结束时，将其他数据流到输出中？
浏览 1提问于2016-10-01得票数 1
回答已采纳
在阅读了这个、这个包和关于globs 的一些内容之后，我找不到办法使下面的代码片段只过滤没有其父文件夹的JavaScript文件：
gulp.task("distribution", function () {
return gulp.src("distribution/**/*.js", { nodir: true })
.pipe(gulp.dest("www/javascripts"));
});
我得到的是以下文件结构：
javascripts/bootstrap/dist/js/bootstrap.js
java
浏览 4提问于2016-06-26得票数 1
回答已采纳
1回答
我想使用express@4.8.5和管道在NodeJS 0.10.x中流式传输相当大的文件。目前我是这样做的(在CoffeeScript中)：
app.get '/', ( request, response ) ->
input = P.create_readstream route
input
.pipe P.$split()
.pipe P.$trim()
.pipe P.$skip_empty()
.pipe P.$skip_comments()
.pipe P.$parse_csv headers: no, d
浏览 1提问于2014-08-21得票数 1
1回答
出于调试目的，我嗅探了一些来自服务器/客户端的请求和响应。压缩已启用，因此响应将以gzip格式发送。我知道也许我可以禁用mod_deflate但是..。出于好奇，有没有办法在vim中解压gzipped格式的响应？
下面是一个响应示例：
HTTP/1.1 200 OK
Date: Tue, 09 Jul 2013 08:00:18 GMT
Server: Apache/2.2.14 (Ubuntu)
X-Powered-By: PHP/5.3.2-1ubuntu4.19
Content-Disposition: inline; filename="combo"
Last-Modi
浏览 0提问于2013-07-09得票数 1
回答已采纳
from subprocess import PIPE,Popen
p = Popen("ls -l",shell=True,stderr=PIPE,stdout=PIPE)
(out,err) = p.communicate()
print(out, err)
在上面的Popen调用中，如果我删除了stdout=PIPE，在输出中ls -l列出的每个列表之后都会得到换行符。但是如果使用stdout=PIPE，我会显示\n，而不是换行符，如下所示
b'total 67092\n-rw-r--r-- 1 root root 171 May 27 09:08
浏览 2提问于2013-05-27得票数 2
回答已采纳
1回答
我正在Unix环境上运行Python2.7(在Ubuntu和OSX上进行测试)
我有以下节目：
与os.open():
脚本1
import os
pipe_1_name = "pipe_1"
pipe_2_name = "pipe_2"
pipe_3_name = "pipe_3"
def set_connection():
pipe_names = [pipe_1_name, pipe_2_name, pipe_3_name]
for pipe_name in pipe_names:
if os.pat
浏览 3提问于2015-12-02得票数 1
1回答
我有以下python代码：
import pty
import subprocess
os=subprocess.os
from subprocess import PIPE
import time
import resource
pipe=subprocess.Popen(["cat"], stdin=PIPE, stdout=PIPE, stderr=PIPE, \
close_fds=True)
skip=[f.fileno() for f in (pipe.stdin, pipe.stdout, pipe.stderr)]
浏览 0提问于2010-09-22得票数 0
回答已采纳
当命名管道同步工作时，我知道PIPE_WAIT和PIPE_NOWAIT模式之间的区别。文档中对此有非常清楚的说明。
但是，当命名管道异步工作(使用FILE_FLAG_OVERLAPPED)时，它并没有说明这些差异。我在实验中找不到任何不同之处。因此，我假设在这种情况下指定PIPE_WAIT或PIPE_NOWAIT没有区别。对吗？
浏览 3提问于2016-12-01得票数 0
1回答
我一直在做一些翻译工作，从Perl到普通的老式英语。我想知道我是否正确地翻译了这行。
open(FQ, $fqFile =~ /\.gz$/ ? "gunzip -c $fqFile |" : $fqFile)
|| die"Cannot open the pipe to $fqFile\n";
我的翻译是：
#Open a file, $fqFile, by either unzipping it first or just opening it if already unzipped.
浏览 0提问于2016-02-02得票数 0
在一个函数内的.service文件中，我有
let response = this.httpService.request(config)
let result = response.pipe(
map(r=>r.data)
);
return result
服务器可以成功创建返回结果的201响应。但是我想从响应中提取一些数据，然后返回结果。我该怎么做呢？
浏览 0提问于2021-11-15得票数 0
1回答
假设我有一个Rest -列表事件。
POST 203:给出一系列事件。
POST 404:不提供找到的数据。
这是我的密码。
export function httpFetchRetry<T>(source: Observable<T>): Observable<T> {
let errorScanner = (errorCount: number, error: any) => {
if (errorCount >= 5) throw error;
else if (error.status === 404)
浏览 0提问于2019-02-08得票数 1
基本上，我有一个来自http.request的回复。我必须给两个可写的流写信，我有一些关于它的问题：
当我在做
response.pipe(writable1); // Will write very fast
response.pipe(writable2); // Will write slowly
我是否发送了两个gets到响应的源(使用双带宽)？
这段代码有内存问题吗？如果是，具体在哪里？
有一件事我不清楚，我是否必须手动关闭响应，或者我可以相信nodejs会关闭它？
浏览 0提问于2014-11-13得票数 1
回答已采纳
1回答
我正在熟悉nodejs中的streams，我有一个问题：
我有一个我认为可能是最简单的nodejs“回显服务器”，即一个简单的管道返回到响应流的服务器，无论它通过请求流接收到什么。它是有效的，但有一个警告。客户端只有在关闭提交流之后才会收到返回的数据。以下是服务器代码：
var http = require('http')
var server = http.createServer(function (req, res) {
req.pipe(res);
});
server.listen(8000);
下面是我测试它的方法：
做以下工作就很好了
term1> no
浏览 1提问于2013-06-19得票数 8
回答已采纳
下面是脚本：
# Announce intent
puts "\nOpening a Pipe\n"
# and open a pipe to the ls command
set pipe [open "|ls /" "r"]
# Equivalent command under MS-Windows is:
# set pipe [open "!command.com /c dir" "r"]
# read the output of the ls command:
while {![eof $pipe]
浏览 0提问于2020-10-15得票数 0
4回答
对于Express中的某些请求，我有一个小代理。使用库，我有相当简洁的代码：
app.use('/api', function(req, res) {
var url = rewriteUrl(req.url);
var newReq = request(url, function(error) {
if (error) {
logError(error);
}
});
req.pipe(newReq).pipe(res);
});
我的问题是，来自API服务器的响应包含一堆我想要删除的
浏览 47提问于2014-07-31得票数 38
回答已采纳
2回答
用管道动态显示数组长度是可行的吗？这是我的密码：
import { Pipe, PipeTransform } from '@angular/core';
@Pipe({
name: 'lengthOfArray'
})
export class LengthOfArrayPipe implements PipeTransform {
transform(value: any): number {
return value.length;
}
}
我就是这样用的：
组件
listOfIdToExport: any[] = [];
模板
浏览 8提问于2017-06-23得票数 4
回答已采纳
我在将可读流输出到http响应时遇到了问题。
在后台，有来自通用http createServer的常规请求和响应流。我检查'req.url‘是否以css结尾，并创建了该文件的可读流。我在console.log中看到了css内容，其中包含我期望的正确css代码。然后，我尝试通过管道将可读的css文件流传递给响应，但在Chrome中，当我检查响应时，文件响应是空白的。不过，这是一个200的响应。第一眼看上去有什么想法吗？我已经尝试了代码注释掉的不同变体。
router.addRoute("[a-aA-z0-9]{1,50}.css$", function(matches)
浏览 6提问于2014-05-03得票数 0
2回答
写入错误:管道损坏
、、、
我必须在大约300个目录上运行一个工具。每次跑步大约需要1分钟到30分钟，甚至更多。因此，我编写了一个python脚本，该脚本具有一个循环，以在所有目录上逐个运行该工具。
我的python脚本的代码类似于：
for directory in directories:
os.popen('runtool_exec ' + directory)
但是，当我运行python脚本时，我反复收到以下错误消息：
..
tail: write error: Broken pipe
date: write error: Broken pipe
..
我所要做的就是使用ssh登录到一个保存工
浏览 2提问于2010-04-26得票数 4
回答已采纳
在我的视图中，Am循环遍历一个对象数组(如果没有管道，就会显示整个列表)：
<ion-list>
<ion-item *ngFor= "let category of (productCategories | onlyhomecategory) " >
<ion-icon name="arrow-forward" item-right></ion-icon>
{{category.title}}
</ion-item>
</ion-list>
浏览 2提问于2016-06-09得票数 4
回答已采纳
我是NodeJs / Express的新手。我正在尝试创建一个API，这将反过来调用一个现有的API，这基本上是创建一些修改后的产品。基本上，我调用的API "products“使用POST方法。它主要是希望数据以JSON格式传递。但在这里，我从目标API得到错误消息，指出没有传递body。
let json = {"id": "", "name" : ""};
app.get('/createProduct/:product_id', function (req, res) {
浏览 13提问于2020-02-05得票数 1
回答已采纳
我已经编写了一个捕获UDP消息的windows服务，创建一个作为用户的进程，通过命名管道将消息发送到该进程，然后重复。服务在XP中工作得很好，但在windows7中却意外地在一次迭代后终止。事件查看器显示，在我将消息传递给服务之后，出现了一个应用程序错误，随后我的服务意外终止。应用程序错误提示故障模块为ntdll.dll。调试我的服务会显示代码停止的位置。
这是我的工作循环。
do
{
DebugLog("Waiting For UDP message");
if(recvfrom(socketId, buffer, buffSize, 0, &cli
浏览 0提问于2011-06-24得票数 0
回答已采纳
1回答
如何在NodeJS 管道上设置最大缓冲区大小？我试图使用从source下载和管道上传到destination，如下所示：
request(source).pipe(request(destination))
此代码运行良好，但如果文件大小大于AWS内存大小(下图)，则将使崩溃。如果我增加内存，它就能工作，所以我知道不是超时或链接，而是内存分配。最初，我不增加数量，但即使我使用最大值，仍然是1.5GB，而且我希望传输的文件比这更大。
对于这一点，AWS上是否存在NodeJS的全局变量？或者其他建议？
浏览 1提问于2017-07-21得票数 1
使用os.path.exists()成功地测试名为pipe的窗口的存在似乎会阻止管道正常工作。为什么会这样？
下面是名为-管道代码的成功运行窗口：
import time
import multiprocessing as mp
import win32pipe, win32file
PIPENAME = r'\\.\pipe\Foo'
def producer(pipe_name: str):
print('producer')
# if not os.path.exists(pipe_name):
# print(f'
浏览 0提问于2018-07-09得票数 3
回答已采纳
我想了解管道是如何工作的，但我不明白为什么在您使用"ls -l /usr/bin“"grep ls”执行我的程序时，waitpid会被阻塞。如果你去掉-l选项，它是有效的！my_str_tab只需将字符串中的每个单词放入一个字符星号数组。
void command_levels(int *pipe_fd, char **av, int idx, int pipe_save, int pipe_one)
{
if (idx == 1)
dup2(pipe_fd[1], 1);
else if (idx > 1 && av[id
浏览 0提问于2019-04-06得票数 1
3回答
@Pipe({name:'myPipe', pure: false})
我无法理解不洁的管道。
纯净的管道和不纯的管道有什么区别？
请用一个简单和基本的例子来解释。
浏览 5提问于2016-09-02得票数 87
回答已采纳
我正试图在vc++中创建一个命名管道。我已经习惯了C，我希望这个错误不仅仅与我不熟悉c++有关。我使用的代码如下：
#ifdef DEBUG
printf("%s\n%s\n", this->pipe_name, this->pipe_path);
#endif
this->pipe = CreateNamedPipe(
this->pipe_path,
PIPE_ACCESS_DUPLEX,
PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_NOWAIT,
1,
t
浏览 1提问于2017-12-09得票数 0
回答已采纳
1回答
我正在开发一个围绕的网络套接字包装器。System.IO.Pipelines对我来说很有趣，因为它的问题。
我很可能采用以下实现之一：
(不确定该项目到底是什么)
我无法理解IDuplexPipe和Pipe之间的区别。
IDuplexPipe是一种用于支持读写的类型的契约。例如，网络连接将由IDuplexPipe表示。
由于我正在处理的web套接字包装器与Binance的web套接字流相关，所以我假设我需要IDuplexPipe
SignalR使用IDuplexPipe，DotNet.Interactive.PowerShell使用Pipe类。你能用现实
浏览 5提问于2021-12-08得票数 1
回答已采纳
1回答
在这个程序中，两个子进程是分叉的，然后一个通过pipe将字符串发送到另一个。当通信完成后，父进程将被卡在等待从管道(waitpid(read_child, NULL, 0);)读取的子程序的出口中。没有任何waitpid (两个子进程都退出)或者只是等待write_child，它就可以正常工作。为什么会这样呢？
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/wait.h>
int main(in
浏览 3提问于2022-05-07得票数 1
回答已采纳
有人能解释一下创建代理服务器的代码吗？除了最后一个块之外，所有的东西都是有意义的。request.pipe(proxy --我不明白这一点，因为当声明proxy时，它会发出一个请求，并通过管道将其响应传递给客户端的响应。这里我漏掉了什么？为什么我们需要通过管道将原始请求发送给代理，因为http.request方法已经发出了包含在options变量中的请求。
var http = require('http');
function onRequest(request, response) {
console.log('serve: ' + request
浏览 0提问于2014-03-30得票数 5
回答已采纳
我正在尝试使用纯SAS代码解压zip格式的文件，我可以将其集成为SAS脚本的一个步骤。我正在通过SAS Studio on the cloud hosted version (SSOD)的web版本运行SAS。
阅读文档时，我想到了这个，它试图将zip中的所有文件解压缩到同一个目录：
data _null_;
infile "unzip /project/input/file.zip" pipe ;
input ;
put _infile_;
run;
但是我不知道如何告诉它一个特定的目录来写入文件，我也不知道如何从zip文件中提取特定的文件。
浏览 8提问于2018-05-13得票数 0
3回答
我在WMIC.exe程序中遇到了问题(用于查询NodeJS内部的管理工具)。
我可以生成一个wmic.exe进程，但它不会输出任何内容或接受任何输入。但是，如果我将stdin设置为null，它将正确运行并接收输出。
var spawn = require('child_process').spawn;
var wmic = spawn('wmic', [], {stdio: ['ignore']});
wmic.stdout.on('data', function(data) {
console.log('Data
浏览 6提问于2013-08-29得票数 2
回答已采纳
2回答
如何在使用命名管道时防止死锁？
、、、、
我有一个捕获过程，将原始视频数据和音频数据写入文件。像这样的东西将捕获100帧数据。
./capture -n 100 -f video_file -a audio_file
给我一个768000字节的audio_file和414720000字节的video_file。这些似乎与预期的相加：
414720000 == 1920x1080 (像素/帧)*2(字节/像素)* 100 == 48k (Hz) *2(字节/样本)*2通道* 100 (帧)/ 25 (帧/s)
然后当我对这些数据进行编码时
ffmpeg -i audio_file -i video_file out.flv
我确实得到了
浏览 2提问于2011-11-02得票数 3
回答已采纳
我有一个使用的概念http服务器的证明，它使用JSON主体接收POST请求。我试图使用管道和多作者将请求体流到多个POST请求，但它不能正常工作。
在下面的示例中，我可以看到数据被发送到2个POST端点，我可以从这些请求中看到一个日志，但是我始终没有得到响应，似乎代码挂起等待http.Post(...)函数的完成。
如果我直接调用这两个端点，它们可以很好地工作，并给出有效的json响应，所以我认为问题在于这段代码是我的路由处理程序。
func ImportAggregate(c echo.Context) error {
oneR, oneW := io.Pipe()
twoR
浏览 1提问于2018-08-21得票数 0
回答已采纳
我们的安卓应用程序使用安卓捆绑的HttpClient已经有好几年了。我们已经开发了大量的代码来处理与我们的服务器产品的交互。每次调用execute(post)时，HttpClient与服务器的交互如下：
客户端将HTTP POST发送到服务器。
服务器响应401未授权，并提供摘要身份验证挑战。
客户端将HTTP重新发送到服务器，包括摘要身份验证响应(我们在步骤1之前提供了一个CredentialsProvider，因此身份验证响应由HttpClient自动生成)。
服务器接受授权并使用200进行响应。对execute()的调用返回200响应和200响应的正文。
我们遇到
浏览 3提问于2016-06-10得票数 0
回答已采纳
4回答
我正在编写一个类似于生产者-消费者问题的程序。下面是我的主要代码：
public class PipeProcessor {
private volatile boolean close = false;
Pipe pipe;
Output out;
public PipeProcessor(Pipe pipe)
{
this.pipe = pipe;
}
public void run()
{
while(!close)
{
out.output(pipe.get());
}
while(pipe.size() > 0)
浏览 0提问于2009-12-26得票数 1
我试图在客户端UWP C#应用程序和服务器Win32 C++应用程序之间进行通信，这两个应用程序都在同一个包中，我正在使用Win32应用程序作为桌面扩展，为UWP应用程序提供额外的功能。
从中可以清楚地看到，在同一个包中的UWP应用程序之间的命名管道通信，但是对于相同包中的UWP和Win32应用程序还不清楚。
由名为\\\\.\\pipe\\Local\\PipeName的UWP过程创建的管道被转换为\\\\.\\pipe\\Sessions\\<SessionId>\\AppContainerNamedObjects\\<AppContainerSid>\\PipeN
浏览 2提问于2021-01-05得票数 0
当我在.scss文件中使用以下代码时
@import url('//fonts.googleapis.com/css?family=SomeFont:400,700,400italic');
我使用的SASS解析器(nodejs gulp-sass)愉快地从上述位置下载文件，并将其作为纯文本包含在已编译的输出中。
这是我的古尔普文件：
var gulp = require('gulp'),
sourcemaps = require('gulp-sourcemaps'),
autoprefixer = require('gu
浏览 0提问于2015-08-14得票数 5
回答已采纳
1回答
NodeJS请求管
、、、、
我正在为一个技术问题而挣扎，因为我在NodeJS领域很新，我认为我没有适当的好的实践和工具来帮助我解决这个问题。
使用众所周知的请求模块，我正在从远程服务器到客户端制作流代理。如果同时有太多的请求，服务器将不再响应，那么几乎所有的事情都是正常的，直到某个点才能正常工作。实际上，它确实获得了客户端请求，但无法通过流处理并为内容提供服务。
我现在所做的是：
使用http.createServer创建带有http模块的服务器
使用exec从php脚本获取远程url
使溪流畅通
我是怎么做到的：
我试图调查池的内容，但没有理解所有的东西，就像最近添加的池maxSocket一样，但
浏览 5提问于2016-02-01得票数 0
2回答
我需要保存对一个文件的响应。响应是从服务器返回的zip文件，该文件作为blob接收。我需要将blob保存为本地机器上的zip文件。应用程序本身是电子的，文件需要存储在后台(而不打扰用户)。文件类型是zip (需要在此之后解压缩)。
const writer = fs.createWriteStream(path.join(dir, 'files.zip'));
writer.on('pipe', (src) => {
console.log('Something is piping
浏览 0提问于2019-02-21得票数 1
回答已采纳
2回答
角2过滤管
、、
试图编写自定义管道以隐藏某些项目。
import { Pipe } from '@angular/core';
// Tell Angular2 we're creating a Pipe with TypeScript decorators
@Pipe({
name: 'showfilter'
})
export class ShowPipe {
transform(value) {
return value.filter(item => {
return item.visible ==
浏览 0提问于2016-06-15得票数 3
回答已采纳
const p = spawn('ls', ['/'])
console.log('$mark$')
p.stdout.pipe(process.stdout)
上面的代码准确地打印根目录的文件列表，即：
$mark$
bin
boot
data
dev
etc
home
lib
lib64
lost+found
media
mnt
opt
proc
root
run
sbin
solr.log
srv
sys
tmp
usr
var
但是，如果我等一下，比如1秒，它就什么也不打印了。守则如下：
const p = spawn('ls&#
浏览 0提问于2018-11-21得票数 0
3回答
如果我有4个进程，我想通过管道传输：
process1 | process2 | process3 | process4
我必须像这样做三个单独的管子吗？
int pipe1[2];
int pipe2[2];
int pipe3[2];
或者，我是否可以像下面的伪代码中那样重复使用管道名称：
int pipe1[2]; // we use ONLY two pipe names: pipe1
int pipe2[2]; // and pipe2
pipe(pipe1);
浏览 2提问于2011-10-24得票数 1
1回答
我将命令行参数从父级传递到子级，并对它们进行计数和打印。我的问题是，我不确定我是不是在收获这个孩子？我是不是只需要一个出口0，或者我需要再次调用fork？
#include <sys/wait.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
int main(int argc, char *argv[])
{
int length = 0;
int i, n;
int fdest[2];
浏览 0提问于2010-03-01得票数 2
回答已采纳
1回答
我正在写一个bash脚本，我正在寻找一些东西，可以让我发送命令到一个文件，程序将读取和执行。我找到了。从一开始我就开始实验，我意识到有一个很大的问题:如果输入行大约是100个字符，那么从另一边读取失败的可能性就在50%左右。让我举例说明一下发生了什么。
首先，我们需要一个fifo和两个单行分别用于服务器和客户端.
# creating fifo
mkfifo pipe
# a-la server
while true; do \
echo -n 'Send to client: > ';\
read ;\
echo "$REPLY"
浏览 1提问于2014-01-13得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
