Cassandra 脚本将日期更改为即时类型

Question

是否可以更改 cassandra 中的所有数据值 来自：2020-05-18T14:18:45.878Z 到1593402243336（如 Instant Java 类型）

此列中所有数据的类型均为text

我想知道如何编写将日期从例如2020-05-18T14:18:45.878Z 更改为1593402243336 的脚本

Answer 1

在 Cassandra 中，有一个单独的 timestamp 类型来保存此类信息。在内部，它将数据存储为 8 字节长值，以毫秒为单位表示时间。该值通过驱动程序访问，并且可以转换为特定于所使用的编程语言的类型的值。如果您通过cqlsh 访问这些值，则需要将它们打印为2020-05-18T14:18:45.878Z，但实际上它仍然是long 引擎盖下的类型。

要执行这样的转换，您需要两件事：

1. 您需要添加另一列 timestamp 类型 - 您无法更改现有列的类型
2. 您需要使用一些工具来执行这种转换，但这实际上取决于您的要求。你可以这样做，例如：

• Spark - 只需使用Spark Cassandra Connector 执行类似操作

val data = { spark.read.format("org.apache.spark.sql.cassandra")
    .options(Map( "table" -> "", "keyspace" -> ""))
    .load().withColumnRenamed("text_column", "date_column")}
data.write.format("org.apache.spark.sql.cassandra")
   .options(Map("table" -> "", "keyspace" -> "")).mode("append").save()

• DSBulk。您可以将数据库中的数据卸载到磁盘上，然后再加载回来，但是通过提供带有-m 选项的自定义映射来使用时间戳列而不是文本列。有一系列关于 DSBulk 的博客文章，可以提供更多信息和示例：1、2、3、4、5、6