我已经建立了一些管道并成功地从大多数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
}
[列在Source.Projection选项卡中标识为正确,其中的插针为[]字符串,但无法加载源((]
"{"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"}"
我已经建立了一些管道并成功地从大多数CosmosDB表中导入了数据,但是这一过程不断给我一个我不明白的错误。我认为这可能是由于表...
可以通过以下方法解决它:1.重新启动ADF会话2.重置数据源的架构-它自动选择了正确的架构。希望这个答案能对功能有所帮助。