AWS S3

With this integration you can store and access data into amazon S3 buckets.

Official Websitehttps://aws.amazon.com/s3

TagsBucketsFilesSaas

JavaScript

Documentationhttps://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-s3/index.html

NodeJS packagehttps://www.npmjs.com/package/@aws-sdk/client-s3

Version3.316.0

Source Codehttps://github.com/aws/aws-sdk-js-v3/tree/main/clients/client-s3

Python

Documentationhttps://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/s3.html

Pypi packagehttps://pypi.org/project/boto3/

Version1.26.79

Source Codehttps://github.com/boto/boto3

Credential configuration

To fill the form params you need the Access key id and the Secret access key of the Programatic access user you want to use. This user needs the permissions to have access to S3 to work properly. If you need to create the user, you can see how to do it here.

In the extra options field you can pass any of the params you can find here.

Here you have an example of a filled credential configuration form in YepCode:

AWS S3 snippets available in YepCode editor

note

The title is the triggering text for YepCode to autocomplete the script

JavaScript

Integration

New integration from credential

const awsS3Client = yepcode.integration.awsS3("credential-slug");

New integration from plain authentication data

const { S3Client } = require("@aws-sdk/client-s3");

const awsS3Client = new S3Client({
  credentials: {
    accessKeyId: "accessKeyId",
    secretAccessKey: "secretAccessKey",
  },
});

List buckets

List buckets

const { ListBucketsCommand } = require("@aws-sdk/client-s3");

const listBucketsCommand = new ListBucketsCommand({})

const listBucketsResult = await awsS3Client.send(listBucketsCommand);
listBucketsResult.Buckets.forEach(console.log)

Create a bucket

Create a bucket

const { CreateBucketCommand } = require("@aws-sdk/client-s3");

const createBucketCommand = new CreateBucketCommand({ Bucket: "bucket-name" });

awsS3Client.send(createBucketCommand).then(console.log).catch(console.error);

Delete a bucket

Delete a bucket

const { DeleteBucketCommand } = require("@aws-sdk/client-s3");

const deleteBucketCommand = new DeleteBucketCommand({ Bucket: "bucket-name" });

awsS3Client.send(deleteBucketCommand).then(console.log).catch(console.error);

Get file content

Get file content

const { GetObjectCommand } = require("@aws-sdk/client-s3");

const getObjectCommand = new GetObjectCommand({
  Bucket: "bucket-name",
  Key: "object-name",
});

const getObjectResult = await awsS3Client.send(getObjectCommand);

// Result.Body is a stream of object content
getObjectResult.Body.on("data", (data) => console.log(data.toString("utf8")));

Upload file

Upload file

const { PutObjectCommand } = require("@aws-sdk/client-s3");

const putObjectCommand = new PutObjectCommand({
  Body: "Some string body, or stream with defined length",
  Bucket: "bucket-name",
  Key: "object-name",
});

awsS3Client.send(putObjectCommand).then(console.log).catch(console.error);

Upload file with stream

Upload file with stream

const { Upload } = require("@aws-sdk/lib-storage");

const upload = new Upload({
  client: awsS3Client,
  params: {
    Bucket: "bucket-name",
    Key: "object-name",
    Body: readableStream,
  },
});

upload.done().then(console.log).catch(console.error);

Python

Integration

New integration from credential

aws_s3_client = yepcode.integration.aws_s3("credential-slug")

New integration from plain authentication data

import boto3

session = boto3.Session(
    aws_access_key_id="accessKeyId",
    aws_secret_access_key="secretAccessKey",
    region_name="region"
)
aws_s3_client = session.client("s3")

List buckets

List buckets

response = aws_s3_client.list_buckets()

for bucket in response['Buckets']:
    print(bucket)

Create a bucket

Create a bucket

aws_s3_client.create_bucket(Bucket="bucket-name")

Delete a bucket

Delete a bucket

aws_s3_client.delete_bucket(Bucket="bucket-name")

Get file content

Get file content

response = aws_s3_client.get_object(
  Bucket="bucket_name", Key="object_key"
)
file_stream = response['Body']

print(file_stream.read().decode('utf-8'))

Upload file

Upload file

aws_s3_client.put_object(
  Bucket="bucket_name", Key="object_key", Body="object_body"
)

Upload file with stream

Upload file with stream

import io

sample_file_content = """
Sample file content
With 2 lines
"""

content_stream = io.BytesIO()
content_stream.write(sample_file_content.encode('utf-8'))
# Reset stream position to the beginning
content_stream.seek(0)

aws_s3_client.put_object(
  Bucket="bucket_name", Key="object_key", Body=content_stream
)