From 15673e9cab2fcdb53efdad8484f1e5330beba95f Mon Sep 17 00:00:00 2001 From: Jeff Bryner Date: Fri, 7 Mar 2014 15:20:08 -0800 Subject: [PATCH] correct bulk processing for new heka --- loginput/index.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/loginput/index.py b/loginput/index.py index 828eebf5..9fda3f28 100644 --- a/loginput/index.py +++ b/loginput/index.py @@ -33,14 +33,11 @@ def bulkindex(): for i in bulkpost.splitlines(): eventlist.append(i) - if connection is None or connection.is_open==False: - openMQConnection() - for i in eventlist: try: #valid json? try: - eventDict=json.loads(anevent) + eventDict=json.loads(i) except ValueError as e: response.status=500 return