python - Azure Streaming Analytics input/output -

i implemented simple streaming analytics query:

select     collect()     input timestamp ts group     tumblingwindow(second, 3) 

i produce on event hub input python script:

... iso_ts = datetime.fromtimestamp(ts).isoformat() data = dict(ts=iso_ts, value=value) msg = json.dumps(data, encoding='utf-8') # bus_service servicebusservice instance bus_service.send_event(hub_name, msg) ... 

i consume queue:

... while true:     msg = bus_service.receive_queue_message(q_name, peek_lock=false)     print msg.body ... 

the problem cannot see error point in azure portal (the input , output tested , ok), cannot output running process!

i share picture of diagnostic while query running:

can give me idea start troubleshooting?

thank much!

update

ok, guess isolated problem.
first of all, query format should this:

select   collect()   [output-alias]   [input-alias] timestamp ts group   tumblingwindow(second, 3) 

i tried remove timestamp by clause , goes well; so, guess problem clause.

i paste example of json-serialized input data:

{   "ts": "1970-01-01 01:01:17",   "value": "foo" } 

one argue timestamp old (seventies), tried current timestamps , didn't output , error on input.

can imagine going wrong? thank you!

can check service bus queue azure portal number of messages received?