Merge pull request #5 from nsano-rururu/fix_test_rule_error

Fix test_rule.py error

elastalert/test_rule.py

@@ -83,7 +83,7 @@ def test_file(self, conf, args):
 
         # Get one document for schema
         try:
-            res = es_client.search(index, size=1, body=query, ignore_unavailable=True)
+            res = es_client.search(index=index, size=1, body=query, ignore_unavailable=True)
         except Exception as e:
             print("Error running your filter:", file=sys.stderr)
             print(repr(e)[:2048], file=sys.stderr)
@@ -109,7 +109,7 @@ def test_file(self, conf, args):
             five=conf['five']
         )
         try:
-            res = es_client.count(index, doc_type=doc_type, body=count_query, ignore_unavailable=True)
+            res = es_client.count(index=index, doc_type=doc_type, body=count_query, ignore_unavailable=True)
         except Exception as e:
             print("Error querying Elasticsearch:", file=sys.stderr)
             print(repr(e)[:2048], file=sys.stderr)
@@ -153,7 +153,7 @@ def test_file(self, conf, args):
         # Download up to max_query_size (defaults to 10,000) documents to save
         if (args.save or args.formatted_output) and not args.count:
             try:
-                res = es_client.search(index, size=args.max_query_size, body=query, ignore_unavailable=True)
+                res = es_client.search(index=index, size=args.max_query_size, body=query, ignore_unavailable=True)
             except Exception as e:
                 print("Error running your filter:", file=sys.stderr)
                 print(repr(e)[:2048], file=sys.stderr)