нет жизнеспособной альтернативы при вводе: Siddhi Query

Я пытаюсь написать простой запрос сиддхи, просто импортировав настраиваемый отображаемый поток. Но как только я импортирую поток и проверяю запрос, возникает ошибка.

Однако мой полный запрос

@Import('bro.in.ssh.log:1.0.0')
define stream inStream (ts string, uid string, id.orig_h string, id.orig_p int, id.resp_h string, id.resp_p int, version int, client string, server string, cipher_alg string, mac_alg string, compression_alg string, kex_alg string, host_key_alg string, host_key string);

@Export('bro.out.ssh.log:1.0.0')
define stream outStream (ts string, ssh_logins int);

from inStream
select dateFormat (ts,'yyyy-MM-dd HH:mm') as formatedTs, count
group by formatedTs
insert into outStream;

Все, что я хочу, - это подсчитать количество записей в журнале за одну минуту и ​​время экспорта и подсчитать в выходной поток. Но я получаю ошибки даже в самой первой строке. Я ввел файл журнала bro ids, ssh.log. Его образец записи будет примерно таким: {"ts":"2016-05-08T08:59:47.363764Z","uid":"CLuCgz3HHzG7LpLwH9","id.orig_h":"172.30.26.119","id.orig_p":51976,"id.resp_h":"172.30.26.160","id.resp_p":22,"version":2,"client":"SSH-2.0-OpenSSH_5.0","server":"SSH-2.0-OpenSSH_6.6.1p1 Ubuntu-2ubuntu2.6","cipher_alg":"arcfour256","mac_alg":"hmac-md5","compression_alg":"none","kex_alg":"diffie-hellman-group-exchange-sha1","host_key_alg":"ssh rsa","host_key":"8d:df:71:ac:29:1f:67:6f:f3:dd:c3:e5:2e:5f:3e:b4"}


person aneela    schedule 17.06.2016    source источник
comment
Пожалуйста, предоставьте также образец ввода   -  person Tishan    schedule 17.06.2016
comment
Я добавил входную запись, но эта ошибка возникает независимо от ввода. Я пока просто пишу запрос.   -  person aneela    schedule 17.06.2016


Ответы (1)


Сиддхи не допускает, чтобы имя атрибута состояло из точки ('.'). Поэтому отредактируйте поток событий так, чтобы в именах атрибутов (например, id.orig_h) не было символа точки.

person Dilini    schedule 17.06.2016