Запрос аналитики кинесиса AWS для агрегации непрерывного потока с использованием переключающегося окна? - PullRequest
Новая
       37

Запрос аналитики кинесиса AWS для агрегации непрерывного потока с использованием переключающегося окна?

0 голосов
/ 14 февраля 2019

Привет У меня есть насос, который отправляет данные в поток Kinesis как json 

{
   aName:"foo",
   aStatus:"FAILED",
   updateAt: 2019-02-13T23:48:21.732Z
},
{
   aName:"foo",
   aStatus:"FAILED",
   updateAt: 2019-02-13T23:48:22.732Z
},
{
   aName:"moo",
   aStatus:"SUCCESS",
   updateAt: 2019-02-13T23:48:23.732Z
},
{
   aName:"moo",
   aStatus:"FAILED",
   updateAt: 2019-02-13T23:48:24.732Z
},
..........
{
   aName:"foo",
   aStatus:"SUCCESS",
   updateAt: 2019-02-13T23:58:21.732Z
},
{
   aName:"foo",
   aStatus:"FAILED",
   updateAt: 2019-02-13T23:58:22.732Z
},
{
   aName:"moo",
   aStatus:"FAILED",
   updateAt: 2019-02-13T23:58:23.732Z
},
{
   aName:"moo",
   aStatus:"FAILED",
   updateAt: 2019-02-13T23:48:24.732Z
}

Я хочу, чтобы вывод был Что-то вроде 

ANAME |  ASTATUS  |  COUNT
foo     FAILED        2   <-- First Window
moo     FAILED        1   <-- First Window
moo     FAILED        1   <-- First Window
...
foo     FAILED        1   <-- Second Window
foo     SUCCESS        1   <-- Second Window
moo     FAILED        2   <-- Second Window

Каким должен быть SQL дляэто?

...