Spark 2.2.0 - Как перечислить файлы в ведро S3 из EC2 [duplicate]
Я использую следующий код PHP для создания переменной, которую я вставляю в столбец DATETIME MySQL.
$datetime = date_create()->format('Y-m-d H:i:s');
Это будет содержать текущую дату и время сервера.
4
задан raxelsson 27 June 2013 в 12:35
поделиться
4 ответа
Использование библиотеки здесь:
https://github.com/Rhinofly/play-s3
Вы должны быть способны сделать что-то вроде это:
import concurrent.ExecutionContext.Implicits._
val bucket = S3("bucketName")
val result = bucket.list
result.map {
case Left(error) => throw new Exception("Error: " + x)
case Right(list) =>
list.foreach {
case BucketItem(name, isVirtual) => //...
}
}
Вам придется немного подкорректировать это в отношении ваших учетных данных, но примеры показывают, как это сделать.
5
ответ дан cmbaxter 18 August 2018 в 06:34
поделиться
-
1Большое спасибо, помог мне! Я немного изменил его, я опубликую свое решение. – raxelsson 27 June 2013 в 14:11
def listS3Files() = Action {
Await.result(S3("bucketName").list, 15 seconds).fold(
{ error => {
Logger.error("Error")
Status(INTERNAL_SERVER_ERROR)
}},
success => {
Ok(success.seq.toString())
}
)
}
Вот мое рабочее решение. Благодаря @cmbaxter
2
ответ дан raxelsson 18 August 2018 в 06:34
поделиться
Другие вопросы по тегам: