CosmosDB源返回DF-SYS-01

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

我已经建立了一些管道并成功地从大多数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表中导入了数据,但是这一过程不断给我一个我不明白的错误。我认为这可能是由于表...

azure-data-factory-2
1个回答
0
投票

可以通过以下方法解决它:1.重新启动ADF会话2.重置数据源的架构-它自动选择了正确的架构。希望这个答案能对功能有所帮助。

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