小编mil*_*adi的帖子

将数据从一个 s3 连续复制到另一个 s3 存储桶的最佳方法是什么？我了解 S3 支持事件通知并将其发送到 lambda、SNS 和 SQS，但我不确定可以选择做什么？我应该触发 lambda 函数来接收来自 S3 的记录并将它们复制到另一个 s3 中吗？我应该使用 SNS 还是 SQS 来做到这一点？

如何编写一个取整数数组的函数,并返回一个整数数组.返回值应包含输入数组中最常见的整数.

List(5, 4, 3, 2, 4, 5, 1, 6, 1, 2, 5, 4)  => List(5, 4)
List(1, 2, 3, 4, 5, 1, 6, 7)              => List(1)
List(1, 2, 3, 4, 5, 6, 7)                 => List(1, 2, 3, 4, 5, 6, 7)

我已经尝试过以下方法:

def mostFreq(info: List[List[String]]): (String, Int) = 
  info.flatten.groupBy(identity).mapValues(_.size).maxBy(_._2)

但它没有处理关系.

有什么方法可以使用boto3在两个不同的存储桶（源存储桶和目标存储桶）中循环存储桶内容，并且如果它在源存储库中找到与目标不匹配的任何密钥，则会将其上载到目标存储桶。请注意，我不想使用AWS S3同步。我目前正在使用以下代码来完成这项工作：

import boto3

s3 = boto3.resource('s3')
src = s3.Bucket('sourcenabcap')
dst = s3.Bucket('destinationnabcap')
objs = list(dst.objects.all())
for k in src.objects.all():
 if (k.key !=objs[0].key):
  # copy the k.key to target

如何使用 Spark-Scala 连接日期和时间列（均为字符串）

+---+-------------------+-----+
| ID|   Date            |Time
+---+------------------ +-----+
|  G|2014.01.14 00:00:00| 1:00
+---+-------------------+------

"2014.01.14 1:00"