无法从 databricks 编写的 python 脚本中从 cosmos db 选择 _ts。
read_config = {
"spark.cosmos.accountEndpoint": url,
"spark.cosmos.accountKey": key,
"spark.cosmos.database": database,
"spark.cosmos.container": container,
"spark.cosmos.read.customQuery" : "select * from c "
}
rsltdf = spark.read.format("cosmos.oltp").options(**read_config).load()
display(rsltdf)
此选择选择除自动生成的字段(如 _ts、_etag)之外的字段。 _摆脱..
Databricks 运行时版本 - 7.3 LTS(包括 Apache Spark 3.0.1、Scala 2.12)
库 - com.azure.cosmos.spark:azure-cosmos-spark_3-3_2-12:4.18.1、azure-cosmos、pyDocumentDB
正如@David提到的,你需要明确查询
_ts
。
确保为其指定别名。
select c.name ,c._ts as ts, c._etag as etag from c
Output: