From 5abe2111364ff8a911963045994f65cd65369eec Mon Sep 17 00:00:00 2001
From: Alec <asheperd@icecube.wisc.edu>
Date: Fri, 22 Nov 2024 15:15:03 -0600
Subject: [PATCH] update ES script to new 8.16 cluster

---
 requirements-monitoring.txt |  2 +-
 resources/progress_to_es.py | 15 ++++++++++++++-
 2 files changed, 15 insertions(+), 2 deletions(-)

diff --git a/requirements-monitoring.txt b/requirements-monitoring.txt
index af1d231..2b5b067 100644
--- a/requirements-monitoring.txt
+++ b/requirements-monitoring.txt
@@ -36,7 +36,7 @@ deprecated==1.2.14
     #   opentelemetry-exporter-otlp-proto-http
 dnspython==2.6.1
     # via pymongo
-elasticsearch[async]==7.9.1
+elasticsearch[async]==8.16.0
     # via lta (setup.py)
 frozenlist==1.4.1
     # via
diff --git a/resources/progress_to_es.py b/resources/progress_to_es.py
index 52f3dd5..f0c1a45 100644
--- a/resources/progress_to_es.py
+++ b/resources/progress_to_es.py
@@ -185,7 +185,7 @@ def main():
         'CLIENT_SECRET': '',
         'OPENID_URL': 'https://keycloak.icecube.wisc.edu/auth/realms/IceCube',
         'FILE_CATALOG_URL': 'https://file-catalog.icecube.wisc.edu',
-        'ES_ADDRESS': 'http://elk-1.icecube.wisc.edu:9200',
+        'ES_ADDRESS': 'https://elastic.icecube.aq',
         'ES_INDEX': 'long-term-archive',
         'ES_TIMEOUT': 60.,
         'START_DATE': '',
@@ -203,10 +203,22 @@ def main():
     parser.add_argument('-n', '--dry-run', default=False, action='store_true',
                         help='do not ingest into ES, just print')
     parser.add_argument('--log-level', default='info', choices=['debug', 'info', 'warning', 'error'])
+    parser.add_argument('--es_client_id',default=None,
+                        help='ES oauth2 client id')
+    parser.add_argument('--es_client_secret',default=None,
+                        help='ES oauth2 client secret')
+    parser.add_argument('--token_url',default=None,
+                        help='ES oauth2 realm token url')
     args = parser.parse_args()
 
     logging.basicConfig(level=getattr(logging, args.log_level.upper()), format='%(asctime)s %(levelname)s %(name)s : %(message)s')
 
+    es_api = ClientCredentialsAuth(address='https://elasticsearch.icecube.aq',
+                            token_url=args.token_url,
+                            client_secret=args.es_client_secret,
+                            client_id=args.es_client_id)
+    es_token = es_api.make_access_token()
+
     if args.from_file:
         rest_client = None
     else:
@@ -225,6 +237,7 @@ def main():
         request_timeout=config['ES_TIMEOUT'],
         retry_on_timeout=True,
         max_retries=2,
+        bearer_auth=es_token,
     )
 
     c = Collect(