Access Nested JSON Array using stream analytics

Divyesh Ravichandran 96 Reputation points
2020-06-23T23:31:06.03+00:00

I am fairly new to stream analytics and I have been trying to parse a nested JSON Array . I need to access the data under collections. The query I am using is as below. I also tried using getarrayelement before collections but that did not work either. Any help would be highly appreciated.

SELECT
i.headers.eesEventID AS [EventId]
,(GetArrayElement(i.atomicOperations,0)).objectType AS [ObjectType]
,(GetArrayElement(i.atomicOperations,0)).objectValue.id AS [ColorID]
,(GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.yellow.collections.minimumUnits AS [CouponMinimumQuantityTest]
, COALESCE(
(GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.yellow.collections.minimumUnits
,(GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.red.collections.minimumUnits
,(GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.white.collections.minimumUnits
,(GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.blue.collections.minimumUnits
) AS [CouponMinimumQuantity]
, COALESCE(
(GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.yellow.collections.minSP
,(GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.red.collections.minSP
,(GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.white.collections.minSP
,(GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.blue.collections.minSP
) AS [CouponMinimumProductSpend]

INTO
[eventhub-stream-output]
FROM
[eventhub-stream-input] i
PARTITION BY [ColorID]
WHERE cast((GetArrayElement(i.atomicOperations,0)).objectType AS nvarchar(MAX)) = 'ColorEntity'

The JSON I receive is as below

{
"headers": {
"eesEventId": "1568953"
},
"operations": [
{
"objectType": "ColorEntity",
"operationType": "CREATE",
"objectValue": {
"id": "780051",
"offer": {
"boltOn": null,
"colors": {
"basket": null,
"product": {
"yellow": {
"collections": [
{
"minSP": 1,
"minimumUnits": 1
}
],
"logicalOperator": "OR"
},
"red": {
"collections": [
{
"minSP": 1,
"minimumUnits": 1
}
],
"logicalOperator": "OR"
},
"white": {
"collections": [
{
"minSP": 1,
"minimumUnits": 1
}
],
"logicalOperator": "OR"
},
"blue": {
"collections": [
{
"minSP": 1,
"minimumUnits": 1
}
],
"logicalOperator": "OR"
}
}
}
}
}
}
]
}

Azure Stream Analytics
Azure Stream Analytics
An Azure real-time analytics service designed for mission-critical workloads.
333 questions
0 comments No comments
{count} votes

Accepted answer
  1. Divyesh Ravichandran 96 Reputation points
    2020-06-24T19:53:28.357+00:00

    I was able to do it using nested getarrayelement like below

    (GetArrayElement((GetArrayElement(i.atomicOperations,0)).objectValue.offer.colors.product.yellow.collections,0)).minimumUnits AS [CouponMinimumQuantityTest]
    
    0 comments No comments

0 additional answers

Sort by: Most helpful