如何使用基于分区键的Azure流分析来查询数据

Question

我正在按照以下格式将数据发送到流媒体。

[
      {
        "body": {
          "indice": "NIFTY 50",
          "advances": "13",
        },
        "applicationProperties": {
          "id": 3
        },
        "partitionKey": "pk788",
        "EventProcessedUtcTime": "2019-09-27T09:11:18.4997132Z",
        "PartitionId": 1,
        "EventEnqueuedUtcTime": "2019-09-27T09:11:10.3310000Z"
      },
      {
        "body": [
          {
            "symbol": "BAJFINANCE",
            "tradedQuantity": "16,00,866",
          },
     "applicationProperties": {
          "id": 2
        },
        "partitionKey": "pk787",
        "EventProcessedUtcTime": "2019-09-27T09:11:18.4997132Z",
        "PartitionId": 1,
        "EventEnqueuedUtcTime": "2019-09-27T09:11:10.3310000Z"
      }
    ]

我尝试使用以下查询来查询此数据的地方

Select * from NSEStockInput
where partitionKey = 'pk788' 

我收到如下错误发生意外错误。请打开支持通知单以进行调查并提供以下客户端请求ID：undefined如何解决此问题

Answer 1

似乎您的样本不是有效的Json。您能否尝试删除第二个“ body”属性旁边的“ [”。