I'm using lambda nodejs to upload file to ftp server.
the source code for upload file:
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;
the index.js file:
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);
};
The log after run:
Response:
null
Request ID:
"9c8e1701-ad54-42eb-8dc6-bbed77bc9b41"
Function Logs:
START RequestId: 9c8e1701-ad54-42eb-8dc6-bbed77bc9b41 Version: $LATEST
END RequestId: 9c8e1701-ad54-42eb-8dc6-bbed77bc9b41
REPORT RequestId: 9c8e1701-ad54-42eb-8dc6-bbed77bc9b41 Duration: 517.98 ms Billed Duration: 600 ms Memory Size: 128 MB Max Memory Used: 93 MB
It can not upload file to ftp server. Please help me. Thank you.
localhost
? – michaelbahr