因为我们可以使用下面的pyspark将数据读写到cosmosdb中,
cfg = {
"spark.cosmos.accountEndpoint" : "xx:443/",
"spark.cosmos.accountKey" : "xx==",
"spark.cosmos.database" : "graphdb",
"spark.cosmos.container" : "graph" ,
"spark.cosmos.read.customQuery" : "select * FROM c where c.label =Email"
}
cosmosDbFormat = "cosmos.oltp"
df = spark.read.format("cosmos.oltp").options(**cfg).load()同样的,有没有办法用pyspark来删除顶点...
请注意,顶点不会被覆盖,因为它是使用uuid创建的。所以每次在原始表中有删除的顶点都不会被删除..
发布于 2021-08-19 16:30:08
据我所知,无法使用pyspark连接器删除cosmos DB中的顶点。你可以使用cosmos Spark connector to read from or write to cosmos DB。您可以通过使用.drop().来使用Azure数据资源管理器
Azure Cosmos DB Gremlin graph support and compatibility with TinkerPop features
https://stackoverflow.com/questions/68759773
复制相似问题