Приветствую ,помогите пожалуйста, файлы не выгружаются в AWS S3, ошибок также никаких нет
Я использую Apollographql + AWS S3
//resolver(graphql):
fileUpload: async (parent, { file }) => {
const { filename, createReadStream } = await file;
const stream = createReadStream();
let result;
try {
const uploadStream = createUploadStream(filename);
stream.pipe(uploadStream.writeStream);
result = await uploadStream.promise;
} catch (error) {
console.log(
`[Error]: Message: ${error.message}, Stack: ${error.stack}`
);
throw new ApolloError("Error uploading file");
}
return result;
},
streams.js
import { bucket, s3 } from "./bucket.js";
import stream from "stream";
import { Upload } from "@aws-sdk/lib-storage";
export const createUploadStream = (key) => {
const pass = new stream.PassThrough();
return {
writeStream: pass,
promise: new Upload({
client: s3,
params: {
Bucket: bucket,
Key: key,
Body: pass,
}
}),
};
};
bucket.js:
import { S3Client } from "@aws-sdk/client-s3";
export const bucket = process.env.Bucket;
export const s3 = new S3Client({
credentials: {
accessKeyId: "process.env.ACCESS_KEY_ID",
secretAccessKey: "process.env.ACCESS_KEY_SECRET",
},
region: "eu-central-1",
});