我已经构建了一些管道,并成功地从我的大多数 CosmosDB 表中导入数据,但这个不断给我一个我不明白的错误。我认为这可能是由表格结构引起的,但非常感谢第二意见和可能的解决方案。
表项:
{
"id": "someGuid",
"name": "someString",
"pins": [
{
"type": "someString",
"latitude": 47.03923,
"longitude": -122.89136,
"name": "someString"
},
{
"type": "someString",
"latitude": 28.53823,
"longitude": -81.37739,
"name": "someString"
}
],
"_rid": "vj04AOrfr2s8CT0AAAAAAA==",
"_self": "dbs/vj04AA==/colls/vj04AOrfr2s=/docs/vj04AOrfr2s8CT0AAAAAAA==/",
"_etag": ""ac00ddc8-0000-0700-0000-5e7428230000"",
"_attachments": "attachments/",
"_ts": 1584670755
}
列在">源.投影"选项卡中标识正确,其中引脚为 []字符串,但无法加载源 ((
"{"message":"at : (StructType(StructField(area,StringType,true), StructField(date,StringType,true), StructField(resultType,StringType,true), StructField(results,ArrayType(StringType,true),true), StructField(test,StringType,true)),StringType) (of class scala.Tuple2). Details:at : (StructType(StructField(area,StringType,true), StructField(date,StringType,true), StructField(resultType,StringType,true), StructField(results,ArrayType(StringType,true),true), StructField(test,StringType,true)),StringType) (of class scala.Tuple2)","failureType":"UserError","target":"Pins","errorCode":"DFExecutorUserError"}"
能够通过以下方式解决它:1. 重新启动 ADF 会话 2。重置数据源的架构 - 它会自动选择正确的架构。希望这个答案能帮助该功能中的某个人。