将 curl 上传文件转换为 Node.JS 中的请求并写入 zip 文件

Question

我正在尝试将以下 curl 转换为节点请求。

curl -F files[]=@database.mdb 'https://www.rebasedata.com/api/v1/convert?outputFormat=mysql&errorResponse=zip' -o output.zip

我尝试过使用 request 或 node-libcurl，但找不到上传 mdb 文件的方法。

我的代码是

var request = require('request');

var options = {
    url: 'https://www.rebasedata.com/api/v1/convert?outputFormat=mysql&errorResponse=zip',
    method: 'POST',
    formData: {
        custom_file: {
            options: {
            contentType: 'application/mdb'
        },
            value: path.resolve(__dirname, 'myMdb.mdb') 
        }
    }
};

function callback(error, response, body) {
    if (!error && response.statusCode == 200) {
        console.log(body);
    }
}

request(options, callback);

但我一直收到错误消息，例如没有给出文件或无法打开文件。

感谢任何帮助。

Answer 1

你有一些错误：

• curl语句的key是files[]，不是custom_file，这里只是request文档https://github.com/request/request#multipartform-data-multipart-form-uploads的一个例子。所以请改成files[]
• request 的文档还说值应该是stream，而不是路径
• 您应该要求 path 和 fs 创建流和读取路径文件

已编辑：如何从响应中写入 zip 文件？

你想写zip文件，请参考包JSZiphttps://stuk.github.io/jszip/documentation/howto/read_zip.html。拥有body后，读取zip并写入zip文件。

我已经用新代码解决了你的问题，回调处理程序来自request 的文档，你可以忽略我的回调处理程序。

更新的 zip 文件

安装前请先安装包jszip

npm install jszip --save

这是代码，请在请求时添加encoding: null：

var request = require('request');
var path = require('path');
var fs = require('fs');
var JSZip = require("jszip");

function callback(error, response, body) {
    if (error || response.statusCode !== 200) {
        console.log(error);
        return;
    }
    JSZip.loadAsync(body).then(zip => {
        console.log(zip.files);
        zip.generateNodeStream({ type: 'nodebuffer', streamFiles: true })
            .pipe(fs.createWriteStream(path.join(__dirname, './out.zip')))
            .on('finish', function () {
                console.log("File written");
            });
    }).catch(err => console.log(err))
}

request({
    url: 'https://www.rebasedata.com/api/v1/convert?outputFormat=mysql&errorResponse=zip',
    method: 'POST',
    encoding: null, // <--------- important ----------
    formData: {
        'files[]': {
            options: {
                filename: 'database.mdb',
                contentType: 'application/mdb'
            },
            value: fs.createReadStream(path.resolve(__dirname, './database.mdb'))
        }
    }
}, callback);

我的文件database.mdb 上传到这里https://ufile.io/prnsi（文件将在发布答案后 30 天后删除）。

当console.log(zip.files);，你会从我的数据库文件中收到

{ 'data.sql':
   { name: 'data.sql',
     dir: false,
     date: 2018-12-17T02:09:08.000Z,
     comment: null,
     unixPermissions: 33206,
     dosPermissions: null,
     _data:
      { compressedSize: 643,
        uncompressedSize: 1817,
        crc32: 1832401262,
        compression: [Object],
        compressedContent: <Buffer 9d 54 6d 6f a2 40 10 fe 7c fc 8a b9 4f da 56 da c5 7a 46 bd 98 88 b0 b6 44 5c ae 80 f7 d2 2f 88 b0 6d 49 10 1a 5e 9a f6 df df 02 be 80 40 7a 39 02 c9 ... > },
     _dataBinary: true,
     options: { compression: null, compressionOptions: null } } }

Answer 2

看起来您可能有两个问题：

1234563 /li>

1. 您传递的是字符串（文件名），而不是流（文件内容）。

   李>

试试这样的：

var request = require('request');

var options = {
    url: 'https://www.rebasedata.com/api/v1/convert?outputFormat=mysql&errorResponse=zip',
    method: 'POST',
    formData: {
        'files[]': {
            options: {
                contentType: 'application/mdb'
            },
            value: fs.createReadStream(path.resolve(__dirname, 'myMdb.mdb'))
        }
    }
};

function callback(error, response, body) {
    if (!error && response.statusCode == 200) {
        console.log(body);
    }
}

request(options, callback);

（我也会研究https://github.com/request/request-promise；它具​​有相同的请求格式，但您可以放弃回调并改用承诺，这被认为是惯用的，从长远来看会更容易。）