Как запрашивать данные с помощью Azure Stream Analytics на основе ключа раздела - PullRequest
Новая
       82

Как запрашивать данные с помощью Azure Stream Analytics на основе ключа раздела

0 голосов
/ 27 сентября 2019

Я отправляю данные в потоковом режиме, как показано ниже. 

[
      {
        "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'

Я получаю ошибку какниже произошла непредвиденная ошибка.Пожалуйста, откройте заявку в службу поддержки для расследования и укажите следующий идентификатор запроса клиента: undefined Как решить эту проблему

1 Ответ

0 голосов
/ 28 сентября 2019

Похоже, ваш образец не является действительным Json.Пожалуйста, попробуйте удалить '[' рядом со вторым свойством "body".

...