dump from logstash to json serially

dump-es.py

import elasticsearch
from elasticsearch import helpers
import json


es = elasticsearch.Elasticsearch()

zz= helpers.scan(es,
    query={"query":{"filtered": {"filter": {"bool": {"must_not": [], "must": [
 {"range": {"@timestamp": {"gte": 1488365745648, "lte": 1488378342740}}}]}}, "query": {"query_string": {"analyze_wildcard": True, "query": "project: \"fr-staffapp\""}}}}},
    index="logstash-*"
    ,size=1000
)

v = 0
prevOne = ''
sp = ''
with open("fr-staffapp.json", "w") as f:
    f.write('[\n')
    for __, g in enumerate(zz):
        v += 1
        if prevOne:
            f.write(json.dumps(prevOne) + ',\n')
        prevOne = g
    if v == 1:
        sp = ''
    if prevOne:
        f.write(sp + json.dumps(prevOne))
    print "Wrote ", v, " records"
    f.write('\n]')