0
我正在編寫一個SQL,它在出現特定條件時輸出一行。這是連接到一個流,然後調用Lambda。當這種情況在短時間內多次表明爲真時,問題就來了。每隔N分鐘我只想觸發一次Lambda。Kinesis Analytics SQL:Throtte每N分鐘只有1行
我的解決方案從DESTINATION_SQL_STREAM
中讀取N分鐘的滑動窗口,如果count(*)== 0,則發送一個新行,但出現錯誤Object definition contains recursive cycle
。
有沒有辦法做到這一點?