无法从databricks中的Cosmos db中选择_ts

问题描述 投票:0回答:1

无法从 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

python databricks azure-cosmosdb azure-databricks
1个回答
0
投票

正如@David提到的,你需要明确查询

_ts

确保为其指定别名。

select c.name ,c._ts as ts, c._etag as etag from c

Output:

enter image description here

© www.soinside.com 2019 - 2024. All rights reserved.