ingest: configurable ES indexv0.3.2

1 files changed, 4 insertions, 1 deletions

diff --git a/python/fatcat_ingest.py b/python/fatcat_ingest.py
index c6f27ad3..68676ad2 100755
--- a/python/fatcat_ingest.py
+++ b/python/fatcat_ingest.py
@@ -27,7 +27,7 @@ def _init_search(args):
     args.api.get_changelog()
 
     client = elasticsearch.Elasticsearch(args.elasticsearch_endpoint)
-    search = Search(using=client, index="fatcat_release")
+    search = Search(using=client, index=args.elasticsearch_index)
     return search
 
 
@@ -186,6 +186,9 @@ def main():
     parser.add_argument('--elasticsearch-endpoint',
         default="https://search.fatcat.wiki",
         help="elasticsearch API. internal endpoint preferred, but public is default")
+    parser.add_argument('--elasticsearch-index',
+        default="fatcat_release",
+        help="elasticsearch index to query")
     parser.add_argument('--env',
         default="dev",
         help="Kafka topic namespace to use (eg, prod, qa, dev)")