aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@robocracy.org>2020-04-08 11:47:33 -0700
committerBryan Newbold <bnewbold@robocracy.org>2020-04-08 11:47:33 -0700
commitd842983d55fd13b4a006a3caa384e68c70ce998c (patch)
tree676fc9b036cd6c51035e11820446cbef953e7c1e
parent94544a6b32064d299a93025b48297070db2edcd8 (diff)
downloadfatcat-d842983d55fd13b4a006a3caa384e68c70ce998c.tar.gz
fatcat-d842983d55fd13b4a006a3caa384e68c70ce998c.zip
ingest: configurable ES indexv0.3.2
-rwxr-xr-xpython/fatcat_ingest.py5
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)")