Creates a Resource that using passed-by-parameter AWS configurations, it encodes the acquisition and release of the resources needed to instantiate the S3.

Example

import cats.effect.Resource
import monix.eval.Task
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider
import software.amazon.awssdk.regions.Region

val defaultCredentials = DefaultCredentialsProvider.create()
val s3Resource: Resource[Task, S3] = S3.create(defaultCredentials, Region.AWS_GLOBAL)

Creates a new S3 instance out of the the passed AWS configurations.

It provides a fast forward access to the S3 that avoids dealing with Resource, however in this case, the created resources will not be released like in create.

Thus, it is the user's responsibility of the user to do a proper resource usage and closing the connection.

Example

import monix.execution.Scheduler.Implicits.global
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider
import software.amazon.awssdk.regions.Region

val defaultCred = DefaultCredentialsProvider.create()
val s3: S3 = S3.createUnsafe(defaultCred, Region.AWS_GLOBAL)
// do your stuff here
s3.close.runToFuture

Creates a instance of S3 out of a S3AsyncClient.

It provides a fast forward access to the S3 that avoids dealing with Resource.

Unsafe because the state of the passed S3AsyncClient is not guaranteed, it can either be malformed or closed, which would result in underlying failures.

Example

import java.time.Duration
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider
import software.amazon.awssdk.regions.Region.AWS_GLOBAL
import software.amazon.awssdk.http.nio.netty.NettyNioAsyncHttpClient
import software.amazon.awssdk.services.s3.S3AsyncClient

// the exceptions related with concurrency or timeouts from any of the requests
// might be solved by raising the `maxConcurrency`, `maxPendingConnectionAcquire` or
// `connectionAcquisitionTimeout` from the underlying netty http async client.
// see below an example on how to increase such values.

val httpClient = NettyNioAsyncHttpClient.builder()
  .maxConcurrency(500)
  .maxPendingConnectionAcquires(50000)
  .connectionAcquisitionTimeout(Duration.ofSeconds(60))
  .readTimeout(Duration.ofSeconds(60))
  .build()

val s3AsyncClient: S3AsyncClient = S3AsyncClient
  .builder()
  .httpClient(httpClient)
  .credentialsProvider(DefaultCredentialsProvider.create())
  .region(AWS_GLOBAL)
  .build()

  val s3: S3 = S3.createUnsafe(s3AsyncClient)

Provides a resource that uses the values from the config file to acquire and release a S3 instance.

The config will come from MonixAwsConf which it is actually obtained from the application.conf file present under the resources folder.

Example

import monix.connect.aws.auth.MonixAwsConf
import monix.eval.Task
import monix.connect.s3.S3

val awsConf: Task[MonixAwsConf] = MonixAwsConf.load()
S3.fromConfig(awsConf).use { s3 =>
       //business logic here
       Task.unit
 }

Provides a resource that uses the values from the config file to acquire and release a S3 instance.

The config will come from MonixAwsConf which it is actually obtained from the application.conf file present under the resources folder.

Example

import monix.connect.aws.auth.MonixAwsConf
import monix.connect.s3.S3
import monix.eval.Task
import software.amazon.awssdk.regions.Region

MonixAwsConf.load().flatMap{ awsConf =>
    // you can update your config from code too
    val updatedAwsConf = awsConf.copy(region = Region.AP_SOUTH_1)
    S3.fromConfig(updatedAwsConf).use { s3 =>
       //business logic here
       Task.unit
    }
}

Provides a resource that uses the values from the config file to acquire and release a S3 instance.

It does not requires any input parameter as it expect the aws config to be set from application.conf, which has to be placed under the resources folder and will overwrite the defaults values from: https://github.com/monix/monix-connect/blob/master/aws-auth/src/main/resources/reference.conf.

Example

import monix.connect.aws.auth.MonixAwsConf
import monix.connect.s3.S3
import monix.eval.Task

S3.fromConfig.use { s3 =>
   //business logic here
   Task.unit
}

Provides a resource that uses the values from the config file to acquire and release a S3 instance.

It does not requires any input parameter as it expect the aws config to be set from application.conf, which has to be placed under the resources folder and will overwrite the defaults values from: https://github.com/monix/monix-connect/blob/master/aws-auth/src/main/resources/reference.conf.

Example

import monix.connect.aws.auth.MonixAwsConf
import monix.connect.s3.S3
import monix.eval.Task

S3.fromConfig.use { s3 =>
   //business logic here
   Task.unit
}