AWS Lambda nodejs将文件上传到ftp

Question

我正在使用lambda nodejs将文件上传到ftp服务器。

上传文件的源代码:

const ftp = require('basic-ftp');
const fs = require('fs');

class FTPClient {
    constructor(host = 'localhost', port = 21, username = 'anonymous', password = 'guest', secure = false) {
        this.client = new ftp.Client();
        this.settings = {
            host: host,
            port: port,
            user: username,
            password: password,
            secure: secure
        };
    }

    upload(sourcePath, remotePath) {
        let self = this;
        (async () => {
            try {
                let access = await self.client.access(self.settings);
                let upload = await self.client.upload(fs.createReadStream(sourcePath), remotePath);
            } catch(err) {
                console.log(err);
            }
            self.client.close();
        })();
    }

    close() {
        this.client.close();
    }
}

module.exports = FTPClient;

index.js文件：

const createCsvWriter = require('csv-writer').createObjectCsvWriter;
const ftp = require('./upload');
const request = require('request');

let doRequest = async (url) => {
    return new Promise(function (resolve, reject) {
        request(url, function (error, res, body) {
            if (!error && res.statusCode == 200) {
                resolve(body);
            } else {
                reject(error);
            }
        });
    });
}


let createFile = async (data) => {
    let fileName = 'fileName.csv';

    const csvWriter = createCsvWriter({
        path: '/tmp/fileName.csv',
        header: [
            { id: 'date', title: 'Date' },
            { id: 'mac_address', title: 'MAC_Address' },
            { id: 'enter', title: 'Enter' }
        ]
    });

    await csvWriter.writeRecords(data);

    const client = new ftp('ftphost', 21, 'ftp_username', 'ftp_password');

    await client.upload('/tmp/fileName.csv', fileName);
}

exports.handler = async (event, s3FileStreamContent) => {

    let dataExcel = [];
    let url = 'http://example.com/apiUrl';//only for example

    let res = await doRequest(url);
    let data = JSON.parse(res).data;


    dataExcel.push({
        date: data.date,
        mac_address: data.mac,
        enter: data.enter
    });

    createFile(data);
};

运行后的日志:

回应:

零

请求ID：

“9c8e1701-ad54-42eb-8dc6-bbed77bc9b41”

函数日志：

开始请求id:9c8e 1701-ad54-42e b-8dc 6-bbed 77 BC 9 b 41版本:$最新

结束请求ID：9c8e1701-ad54-42eb-8dc6-bbed77bc9b41

报告请求 Id： 9c8e1701-ad54-42eb-8dc6-bbed77bc9b41 持续时间： 517.98 毫秒 计费持续时间： 600 毫秒 内存大小： 128 MB 最大使用内存： 93 MB

它不能上传文件到ftp服务器。请帮帮我。谢谢。

Answer 1

请提供你遇到的错误。可能性如下:

const handler = async (event) => {
   }
  module.exports = { handler }

. AWS lambda以aws handler函数开头，希望您已将其包含在您的aws lambda代码中……您如何触发代码。希望您为事件测试配置提供价值。