在 Azure 流分析查询中，我在使用时间戳时遇到错误

Question

我有一些数据要进来，我需要计算流中每分钟值的份数。以下是我的查询

WITH first AS (
SELECT
   TS.ArrayIndex,
   TS.ArrayValue.FQN,
   TS.ArrayValue.vqts
FROM
  [EventHubInput] as hub
CROSS APPLY GetArrayElements(hub.timeseries) AS TS )

SELECT first.FQN ,( max(cast(vqt.arrayvalue.v as BIGINT))-(min(cast(vqt.arrayvalue.v as BIGINT)))) AS PPM  
FROM first  
CROSS APPLY GetArrayElements(first.vqts) AS vqt where first.FQN like '%Production%' and vqt.arrayvalue.q = 192 
timestamp by
vqt.arrayvalue.t
group by 
first.FQN, TumblingWindow(minute, 1)

添加时间戳时出现错误 vqt.arrayvalue.t

我的输入数据是这样的..

{
  "timeSeries": [
    {
        "fqn":"MyEnterprise.Gateways.GatewayE.CLX.Tags.StateBasic",
            "vqts":[
                    {
                    "v": "" ,
                    "q": 192 ,
                    "t":"2016-06-24T16:39:45.683+0000"
                    }
        ]
    },              {
        "fqn":"MyEnterprise.Gateways.GatewayE.CLX.Tags.ProductionCount",
            "vqts":[
                    {
                    "v": 264 ,
                    "q": 192 ,
                    "t":"2016-06-24T16:39:45.683+0000"
                    }
        ]
    },              {
        "fqn":".Gateways.GatewayE.CLX.Tags.StateDetailed",
            "vqts":[
                    {
                    "v": "" ,
                    "q": 192 ,
                    "t":"2016-06-24T16:39:45.683+0000"
                    }
        ]
    }           ]

}

如果有人能帮忙就太好了！！

Answer 1

流中的单个事件只能有一个时间戳字段。您当前正在做的是为此事件中的每个单独的数组值分配时间戳。不幸的是，这目前不受支持。

可能的解决方法是将您的 ASA 作业一分为二。第一个不会使用 TIMESTAMP BY，但会执行 CROSS APPLY 并将数组值作为单个事件发送到中间事件中心。第二个作业将从那里读取，使用 TIMESTAMP BY 并应用其余的逻辑。

在 Azure 流分析查询中，我在使用时间戳时遇到错误

In Azure Stream Analytics Query I am getting an error when using Timestamp by

azure-stream-analytics