我正在从 S3 流式传输一个 xml 文件。我需要为 sphinx 搜索引擎构建一个具有不同结构的新 xml 文件。我已经从 S3 流式传输文件，将其通过管道传输到我的 SAX 解析器，但现在我需要弄清楚如何对流进行修改（在 SAX 解析器之后）并上传到 S3。
parser.on('startElement', function(name, attrs) {
// Do something
});
我发现似乎是一个很棒的 S3 库，它名为knox，所以我目前正在使用该库。我没有被困在这个图书馆上，只是我发现它似乎很不错。在示例中，他们必须将数据流式传输到 S3 的代码仅来自 HTTP 请求。我对流比较陌生，因为我有 PHP 背景。
诺克斯示例流：
http.get('http://google.com/doodle.png', function(res){
var headers = {
'Content-Length': res.headers['content-length']
, 'Content-Type': res.headers['content-type']
};
client.putStream(res, '/doodle.png', headers, function(err, res){
// Logic
});
});
我想我需要在这方面做点什么。
parser.on('startElement', function(name, attrs) {
var headers = {
'Content-Length': res.headers['content-length']
, 'Content-Type': res.headers['content-type']
};
client.putStream(res, '/doodle.png', headers, function(err, res){
// Logic
});
});
任何帮助是极大的赞赏。谢谢。