Cargue y descargue objetos en SAP BTP Object Store en AWS con NodeJS

en el tutorial Crear servicio de almacenamiento de objetos de consumo de aplicaciones de varias nubes , el método que consume el servicio de almacenamiento de objetos en AWS con Java se ha presentado en detalle . En portal de ayuda

también se ha introducido el método en Java.

en el blog Conexión al almacén de objetos BTP de SAP que se ejecuta en la plataforma Microsoft Azure mediante NodeJS

Ujala Kumar Panda ha introducido el uso de nodejs para consumir BTP Object Store en Azure.

Hoy quiero presentar el método con nodjs en una aplicación MTA. usaré Cliente S3: SDK de AWS para JavaScript v3 para consumir el servicio.

Requisito previo:

1, has instalado Cliente CF .

2, has instalado Nodejs .

3, has instalado Herramienta de creación de MTA en la nube .

4, has instalado Código VSC (Opcional).

Pasos :

Paso 1: configurar el almacén de objetos para usar Amazon Simple Storage Service.

Puede seguir el documento en ayudar. Las siguientes son las capturas de pantalla:

Como resultado, encontrará la información de la credencial y la anotará.

Paso 2: Generar proyecto SAPUI5 con generador-safanaacademy-mta

Abre la aplicación con código visual.

Paso 3: agregue el paquete aws-sdk y formidable en package.json en srv.

Paso 4: cambie server.js en srv de la siguiente manera

Las siguientes constantes son de la credencial del paso 1.

const regionV = “eu-central-1”;

const endPointV = “s3-eu-central-1.amazonaws.com”;

const accessKeyIdV = “AKIA5PG4D”;

const secretAccessKeyV = “2cj70kOURiRIYZGQfrxZ”;

const cuboV = «hcp-6d995ea54163b1be»;

const express = require('express');
const app = express();
const fs = require('fs');
const bodyParser = require('body-parser');
const formidable = require('formidable');
const { S3Client, PutObjectCommand, ListObjectsCommand, GetObjectCommand } = require("@aws-sdk/client-s3");

const regionV = "eu-central-1";
const endPointV = "s3-eu-central-1.amazonaws.com";
const accessKeyIdV = "AKIA5PG";
const secretAccessKeyV = "2cj70kGQfrxZ";
const bucketV = "hcp-61ea54163b1be";

const xsenv = require('@sap/xsenv');
xsenv.loadEnv();
const services = xsenv.getServices({
    uaa: { tag: 'xsuaa' }
});


const xssec = require('@sap/xssec');
const passport = require('passport');
passport.use('JWT', new xssec.JWTStrategy(services.uaa));
app.use(passport.initialize());
app.use(passport.authenticate('JWT', {
    session: false
}));

function makeid(length) {
    var result="";
    var characters="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
    var charactersLength = characters.length;
    for (var i = 0; i < length; i++) {
        result += characters.charAt(Math.floor(Math.random() * charactersLength));
    }
    return result;
}

app.use(bodyParser.json());
// app.use(bodyParser.urlencoded({ extended: true }));

app.get('/srv/s3', function (req, res) {
    if (req.authInfo.checkScope('$XSAPPNAME.User')) {
        const client = new S3Client({ region: regionV, endPoint: endPointV, credentials: { accessKeyId: accessKeyIdV, secretAccessKey: accessKeyIdV } });
        var keyid = makeid(5).concat(".txt");
        var content = makeid(5);

        const params =
        {
            Bucket: bucketV, // The name of the bucket. For example, 'sample_bucket_101'.
            Key: keyid, // The name of the object. For example, 'sample_upload.txt'.
            Body: content // The content of the object. For example, 'Hello world!".
        };
        const putCommand = new PutObjectCommand(params);
        client.send(putCommand).then(data => {
            res.status(200).send(data);
        }).catch(err => {
            res.status(500).send(err);
        });
    } else {
        res.status(403).send('Forbidden');
    }
});

app.post('/srv/s3/upload', function (req, res) {
    const form = new formidable.IncomingForm();
    const client = new S3Client({ region: regionV, endPoint: endPointV, credentials: { accessKeyId: accessKeyIdV, secretAccessKey: secretAccessKeyV } });
    const params =
    {
        Bucket: bucketV, // The name of the bucket. For example, 'sample_bucket_101'.
        Key: "",
        Body: ""
    };
    form.parse(req, function (err, fields, files) {

        if (err) {
            return res.status(400).json({ error: err.message });
        }
        const [firstFile] = Object.values(files);

        params.Key = firstFile.originalFilename;
        const file = fs.readFileSync(firstFile.filepath);
        params.Body = file;
        const putCommand = new PutObjectCommand(params);
        client.send(putCommand).then(data => {
            res.status(200).send(data);
        }).catch(err => {
            console.log(err);
            res.status(500).send(err);
        });
    });
});

app.post('/srv/s3/download', function (req, res) {
    const client = new S3Client({ region: regionV, endPoint: endPointV, credentials: { accessKeyId: accessKeyIdV, secretAccessKey: secretAccessKeyV } });
    var keyV = req.body.key;
    const params =
    {
        Bucket: bucketV,
        Key: keyV,
    };
    const getCommand = new GetObjectCommand(params);
    client.send(getCommand).then(data => {
        console.log(data);
        const chunks = []
        const stream = data.Body;
        stream.on('data', chunk => chunks.push(chunk));
        stream.once('end', () => res.status(200).send(chunks));
    }).catch(err => {
        console.log(err.message);
        res.status(500).send(err.message);
    });

});


app.get('/srv/s3/list', function (req, res) {
    if (req.authInfo.checkScope('$XSAPPNAME.User')) {
        const client = new S3Client({ region: regionV, endPoint: endPointV, credentials: { accessKeyId: accessKeyIdV, secretAccessKey: secretAccessKeyV } });

        const params =
        {
            Bucket: bucketV // The name of the bucket. For example, 'sample_bucket_101'.

        };
        const putCommand = new ListObjectsCommand(params);
        client.send(putCommand).then(data => {
            res.status(200).send(data);
        }).catch(err => {
            res.status(500).send(err);
        });
    } else {
        res.status(403).send('Forbidden');
    }
});

app.get('/srv', function (req, res) {
    if (req.authInfo.checkScope('$XSAPPNAME.User')) {
        res.status(200).send('objstore');
    } else {
        res.status(403).send('Forbidden');
    }
});

app.get('/srv/user', function (req, res) {
    if (req.authInfo.checkScope('$XSAPPNAME.User')) {
        res.status(200).json(req.user);
    } else {
        res.status(403).send('Forbidden');
    }
});

const port = process.env.PORT || 5001;
app.listen(port, function () {
    console.info('Listening on http://localhost:' + port);
});