Это вторая часть моего путешествия, чтобы попытаться загрузить файл из браузера в корзину S3.Проверьте Часть первая .
Что я пытаюсь сделать
Загрузить файл (PDF) из моего клиента браузера (приложение Vue / Nuxt) в корзину S3.
Что я использую
Front End
Nuxt, Vue, Axios, Fetch.
Back End
JS,Serverless Framework для простого развертывания AWS.
Разрешения
Разрешения хороши, если только нет разрешения относительно размещения POST в корзине S3, о котором я не знаю.Контейнер S3 настроен для разрешения CORS;все методы, все происхождение. Нет, лямбда, показанная здесь, не имеет неправильных разрешений ;в противном случае я не смог бы получить предварительно подписанный URL-адрес успешно.
Как это должно работать
На основе это и это , Я думал, что смогу PUT (или POST) PDF-файл в корзину S3, сначала извлекая предварительно подписанный URL-адрес из моего внутреннего кода, показанного ниже, который называется s3.getSignedUrl('putObject')
.Мне было легко получить этот URL-адрес для внешнего интерфейса, но PUT (или POSTing) PDF-файл к возвращенному URL-адресу не работал.
То, что я делал в первой части, оказалось бесполезным, и я не быля смог найти ответ на вопрос, почему, поэтому я решил попробовать другую функцию JS AWS SDK под названием createPresignedPost
.
Вместо ошибки 403 я получаю ошибку 412.После прочтения казалось, что я не передаю правильные параметры в запросе POST.Посмотрев на это, я настроил свой запрос, как показано ниже, но все равно получил ошибку.
Код
Backend (fileReceiver.js):
const getUploadUrl = async () => {
const fileId = uuidv4();
let params = {
Bucket: 'the-chumiest-bucket',
ContentType: 'application/pdf',
Conditions: [
{'bucket': 'the-chumiest-bucket'}, // added to both places
['starts-with', '$key', 'path/to/where/the/file/should/go/'],
{'acl': 'public-read'},
{'success_action_status': '200'},
['content-length-range', 1, 1024 * 1024 * 15],
['starts-with', '$Content-Type', 'application/pdf'],
]
};
return new Promise((resolve, reject) => {
s3.createPresignedPost(params, function(err, data) {
if (err) {
console.error('Presigning post data encountered an error', err);
reject(err);
} else {
//data.Fields.key = 'path/to/uploads/${filename}';
console.log('The post data is', data);
resolve({
'statusCode': 200,
'headers': {
'Access-Control-Allow-Origin': '*',
'Access-Control-Allow-Headers': '*',
'Access-Control-Allow-Credentials': true,
'Content-Type': 'application/pdf',
},
'body': JSON.stringify({
'data': data,
}),
});
}
});
});
};
Frontend(fileUploader.js):
Я хотел структурировать свой запрос так, чтобы он соответствовал , этому и , этому .
uploadFile: async function(e) {
const response = await axios({
method: 'get',
url: API_GATEWAY_URL,
data: {
'fileName': this.fileNames[0],
'contentType': this.file.type || 'application/pdf',
'fileLength': this.file.length,
},
body: {
'fileName': this.fileNames[0],
'contentType': this.file.type || 'application/pdf',
'fileLength': this.file.length,
},
});
console.log('upload file response:', response);
let binary = atob(this.file.split(',')[1]);
let array = [];
for (let i = 0; i < binary.length; i++) {
array.push(binary.charCodeAt(i));
}
let fields = response.data.data.fields;
let blobData = new Blob([new Uint8Array(array)], {type: 'application/pdf'});
if (blobData.type != 'application/pdf') {
console.error('Filetype is wrong! Upload a PFD or youre dead to me');
}
console.log(`Uploading "${this.fileNames[0]}" to bucket "${response.data.data.fields.bucket}"`);
const postHeaders = {
'Policy': fields.Policy,
'X-Amz-Algorithm': fields['X-Amz-Algorithm'],
'X-Amz-Credential': fields['X-Amz-Credential'],
'X-Amz-Security-Token': fields['X-Amz-Security-Token'],
'X-Amz-Signature': fields['X-Amz-Signature'],
'Content-Type': blobData.type || 'application/pdf',
'acl': 'public-read',
'key': 'path/to/where/the/file/should/go/' + this.fileNames[0],
}
const result = await fetch(response.data.data.url, {
method: 'post',
body: blobData,
headers: postHeaders,
});
this.uploadUrl = response.data.uploadURL.split('?')[0];
},
Serverless Config (без сервера.yml):
service: ocr-space-service
provider:
name: aws
region: ca-central-1
stage: ${opt:stage, 'dev'}
timeout: 20
plugins:
- serverless-plugin-existing-s3
- serverless-step-functions
- serverless-pseudo-parameters
- serverless-plugin-include-dependencies
layers:
spaceOcrLayer:
package:
artifact: spaceOcrLayer.zip
allowedAccounts:
- "*"
functions:
fileReceiver:
handler: src/node/fileReceiver.handler
role:
events:
- http:
path: /doc-parser/get-url
method: get
cors: true
startStateMachine:
handler: src/start_state_machine.lambda_handler
role:
runtime: python3.7
layers:
- {Ref: SpaceOcrLayerLambdaLayer}
events:
- existingS3:
bucket: ingenio-documents
events:
- s3:ObjectCreated:*
rules:
- prefix:
- suffix: .pdf
startOcrSpaceProcess:
handler: src/start_ocr_space.lambda_handler
role:
runtime: python3.7
layers:
- {Ref: SpaceOcrLayerLambdaLayer}
parseOcrSpaceOutput:
handler: src/parse_ocr_space_output.lambda_handler
role:
runtime: python3.7
layers:
- {Ref: SpaceOcrLayerLambdaLayer}
renamePdf:
handler: src/rename_pdf.lambda_handler
role:
runtime: python3.7
layers:
- {Ref: SpaceOcrLayerLambdaLayer}
parseCorpSearchOutput:
handler: src/node/pdfParser.handler
role:
runtime: nodejs10.x
saveFileToProcessed:
handler: src/node/saveFileToProcessed.handler
role:
runtime: nodejs10.x
stepFunctions:
stateMachines:
ocrSpaceStepFunc:
name: ocrSpaceStepFunc
definition:
StartAt: StartOcrSpaceProcess
States:
StartOcrSpaceProcess:
Type: Task
Resource: "arn:aws:lambda:#{AWS::Region}:#{AWS::AccountId}:function:#{AWS::StackName}-startOcrSpaceProcess"
Next: IsDocCorpSearchChoice
Catch:
- ErrorEquals: ["HandledError"]
Next: HandledErrorFallback
IsDocCorpSearchChoice:
Type: Choice
Choices:
- Variable: $.docIsCorpSearch
NumericEquals: 1
Next: ParseCorpSearchOutput
- Variable: $.docIsCorpSearch
NumericEquals: 0
Next: ParseOcrSpaceOutput
ParseCorpSearchOutput:
Type: Task
Resource: "arn:aws:lambda:#{AWS::Region}:#{AWS::AccountId}:function:#{AWS::StackName}-parseCorpSearchOutput"
Next: SaveFileToProcessed
Catch:
- ErrorEquals: ["SqsMessageError"]
Next: CorpSearchSqsErrorFallback
- ErrorEquals: ["DownloadFileError"]
Next: CorpSearchDownloadFileErrorFallback
- ErrorEquals: ["HandledError"]
Next: HandledNodeErrorFallback
SaveFileToProcessed:
Type: Task
Resource: "arn:aws:lambda:#{AWS::Region}:#{AWS::AccountId}:function:#{AWS::StackName}-saveFileToProcessed"
End: true
ParseOcrSpaceOutput:
Type: Task
Resource: "arn:aws:lambda:#{AWS::Region}:#{AWS::AccountId}:function:#{AWS::StackName}-parseOcrSpaceOutput"
Next: RenamePdf
Catch:
- ErrorEquals: ["HandledError"]
Next: HandledErrorFallback
RenamePdf:
Type: Task
Resource: "arn:aws:lambda:#{AWS::Region}:#{AWS::AccountId}:function:#{AWS::StackName}-renamePdf"
End: true
Catch:
- ErrorEquals: ["HandledError"]
Next: HandledErrorFallback
- ErrorEquals: ["AccessDeniedException"]
Next: AccessDeniedFallback
AccessDeniedFallback:
Type: Fail
Cause: "Access was denied for copying an S3 object"
HandledErrorFallback:
Type: Fail
Cause: "HandledError occurred"
CorpSearchSqsErrorFallback:
Type: Fail
Cause: "SQS Message send action resulted in error"
CorpSearchDownloadFileErrorFallback:
Type: Fail
Cause: "Downloading file from S3 resulted in error"
HandledNodeErrorFallback:
Type: Fail
Cause: "HandledError occurred"
POST-ответ
POST https://s3.{regionName}.amazonaws.com/{bucketName} 412 (предварительное условие не выполнено) PreconditionFailed
По крайней мере одно из указанных вами предварительных условий не выполненоАргумент holdBucket POST должен иметь тип multipart / form-data934186E69EF6F90EAPU1d8pkKL3XxXjZ8T1oXkWWDRECAPZROklZbHBv + lmNRv / ivoLO / 8BhoS8QYXA98850RhrX * 966 * 10 * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * ”кибер-гаджет.1067 *, а не application/pdf
, как я указал
Новый код
Я написал функцию для преобразования PDF в base64 и загрузки его как части FormData
объекта.
convertToBase64(file) {
if (file.length > 0) {
let fileToLoad = file[0];
let fileReader = new FileReader();
let base64;
fileReader.onload = (fileLoadedEvent) => {
console.log('fileLoadedEvent', fileLoadedEvent);
base64 = fileLoadedEvent.target.result;
console.log('base64', base64);
};
fileReader.readAsDataURL(fileToLoad);
} else {
console.log('file length was 0');
}
},
...
let formData = new FormData();
formData.append('pdfFile', this.convertToBase64(this.file));
// upload code from above...
Все еще нет любви!Не уверен, что то, что я пытаюсь сделать, возможно.