Spark S3 credentials tip

s3sample.scala

import geotrellis.spark.io.hadoop._
import geotrellis.spark.util._

import org.apache.hadoop.fs.FileSystem
import org.apache.hadoop.fs.FileUtil
import org.apache.hadoop.fs.Path
import org.apache.hadoop.conf.Configuration
import org.apache.spark._
import org.apache.spark.sql._

val conf = new SparkConf()

conf
  .setMaster("local[*]")
  .setAppName("Test Context")

val sparkContext = SparkSession.builder().config(conf).getOrCreate()

implicit val ssc = sparkContext
val conf = ssc.sparkContext.hadoopConfiguration

// the best way to do it
conf.set("fs.s3.impl", classOf[org.apache.hadoop.fs.s3a.S3AFileSystem].getName)
conf.set("fs.s3a.aws.credentials.provider", classOf[com.amazonaws.auth.DefaultAWSCredentialsProviderChain].getName)
conf.set("fs.s3a.endpoint", "s3.eu-west-2.amazonaws.com")

// it is possible also to specify keys this way
val credentialsProviderChain = new DefaultAWSCredentialsProviderChain
conf.set("fs.s3.impl", classOf[org.apache.hadoop.fs.s3a.S3AFileSystem].getName)
conf.set("fs.s3a.access.key", credentialsProviderChain.getCredentials.getAWSAccessKeyId)
conf.set("fs.s3a.secret.key", credentialsProviderChain.getCredentials.getAWSSecretKey)
conf.set("fs.s3a.endpoint", "s3.eu-west-2.amazonaws.com")

// s3 is deprecated, s3n won't allow to specify the endpoint, so the only really good enough 
// protocol is s3a, and it's the recommended way to interact with S3 using hadoop API.

val df = ssc.read.options(Map("header" -> "true", "inferSchema" -> "true")).csv("s3a://path/to.csv")

@geofflangenderfer both