AWS Lambda nodejs загрузить файл на ftp

Question

Я использую лямбду 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;

индекс. 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);
};

Журнал после запуска:

Ответ:

null

Идентификатор запроса:

"9c8e1701-ad54- 42eb-8dc6-bbed77bc9b41 "

Журналы функций:

START RequestId: 9c8e1701-ad54-42eb-8dc6-bbed77bc9b41 Версия: $ LATEST

END RequestId: 9c54e1701-ad 42eb-8dc6-bbed77bc9b41

REPORT RequestId: 9c8e1701-ad54-42eb-8dc6-bbed77bc9b41 Продолжительность: 517,98 мс Продолжительность счета: 600 мс Размер памяти: 128 МБ Макс. Используемая память: 93 МБ

Не может загрузить файл на FTP-сервер. Пожалуйста, помогите мне. Спасибо.

Answer 1

Пожалуйста, укажите ошибку, с которой вы столкнулись. Возможности, как показано ниже:

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

. AWS лямбда начинается с aws функции-обработчика, надеюсь, вы включили ее в свой aws лямбда-код. Как вы запускаете код. надеюсь, что вы предоставите значение для конфигурации теста событий.