AWS Lambda: сообщение об ошибке завершено перед завершением запроса - PullRequest
0 голосов
/ 12 ноября 2018

Привет, я новичок в Android!

Я хочу загрузить файл изображения с Android-клиента на сервер (сервер создает миниатюры и возвращает URL-адрес миниатюр).

Однако я застрял в этом сообщении об ошибке.

{"errorMessage":"RequestId: 8e2a21b8-e62e-11e8-8585-d9b6fdfec9b9 Process exited before completing request"}!

Я пытался найти этот код ошибки в stackoverflow, но не могу найти ответ для Android.

Пожалуйста, помогите или дайте мне ссылку, где я могу решить эту проблему ...

Вот код сервера.

const AWS = require('aws-sdk');
const multipart = require("parse-multipart");
const s3 = new AWS.S3();
const bluebird = require('bluebird');

exports.handler = function(event, context) {
    let result = [];
    const bodyBuffer = new Buffer(event['body-json'].toString(), 'base64');
    const boundary = multipart.getBoundary(event.params.header['Content-Type']);
    const parts = multipart.Parse(bodyBuffer, boundary);
    const files = getFiles(parts);

    return bluebird.map(files, file => {
        console.log('UploadCall');
        return upload(file)
        .then(
            data => {
                result.push({
                    'bucket': data.Bucket,
                    'key': data.key,
                    'fileUrl': file.uploadFile.fullPath })
                console.log( `DATA => ${JSON.stringify(data, null, 2 )}`);
                },
                err => {
                    console.log(`S3 UPLOAD ERR => ${err}`);
                }
            )
        })
        .then(_=> {
            return context.succeed(result);
        });
    }

    let upload = function(file) {
        console.log('PutObject Call')
        return s3.upload(file.params).promise();
    };

    let getFiles = function(parts) {
    let files = [];
    parts.forEach(part => {
        const buffer = part.data

        const fileName = part.filename;
        const fileFullName = fileName;

        const originBucket = 'dna-edge/images';
        const filefullPath = `https://s3.ap-northeast-2.amazonaws.com/${originBucket}/${fileFullName}`;

        const params = {
            Bucket: originBucket,
            Key: fileFullName,
            Body: buffer
        };

        const uploadFile = {
            size: buffer.toString('ascii').length,
            type: part.type,
            name: fileName,
            fullPath: filefullPath
        };
        files.push({ params, uploadFile })
    });
    return files;
};

А это код клиента. (ImgURL выглядит как /storage/emulated/0/DCIM/img/1493742568136.jpg)

public static String requestHttpPostLambda(String url, String imgURL){

    /*
     await axios.post(`${AWS_LAMBDA_API_URL}?type=${type}`, formData,
{ headers: { 'Content-Type': 'multipart/form-data' }})
.then((response) => {result = response});
     */
    String result=null;
    try {
        HttpClient client = new DefaultHttpClient();
        String postURL = url;
        HttpPost post = new HttpPost(postURL);
        post.setHeader("Content-Type", "multipart/form-data");

        File file = new File(imgURL);
        MultipartEntityBuilder builder = MultipartEntityBuilder.create();
        builder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
        builder.addPart("image", new FileBody(file));
        post.setEntity(builder.build());

        HttpResponse responsePOST = client.execute(post);
        Log.e("HttpResponse", responsePOST.getStatusLine()+"");
        HttpEntity resEntity = responsePOST.getEntity();
        if (resEntity != null) {
            result = EntityUtils.toString(resEntity);
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return result;
}

1 Ответ

0 голосов
/ 12 ноября 2018

Добро пожаловать в stackoverflow.

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

Также я бы перешел на Node 8.10 runtime, потому что тогда вместо использования обещаний / шаблонов вы можете использовать async / await.

export default(event, context, callback) => {

    try {

        // do some stuff

        callback(null, SOME_VALID_HTTP_RESPONSE)
    } catch(e){

        callback(e, null)
    }
}

Есть несколько причин, по которым ваша лямбда могла давать сбой: если процесс завершился до завершения, либо произошел сбой, либо вы не вернули правильный HTTP-ответ (если ваша лямбда находится за шлюзом API)

Два решения - первое место для поиска - облачные часы, найдите имя лямбда-функции и проверьте последний журнал, чтобы найти сообщения об ошибках.

Второе - посмотрите мой ответ здесь , поэтому, когда ваша функция завершится успешно, вам нужно вернуть действительный HTTP-ответ на API-шлюз, поэтому, по сути, если вы используете мой код оттуда, вы можете сделать:

callback(null, responder.success({someJson: someValue}))

Любые вопросы, дайте мне знать :-)

РЕДАКТИРОВАТЬ: я обновляю этот вопрос, я просто работаю над примером для загрузки нескольких файлов на S3!

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...