add cli support

Author: wasin-waeosri

Python/rdp_apis_console.py

@@ -1,19 +1,26 @@
 import os
 import json
 import sys
+import argparse
 from dotenv import load_dotenv
-from icecream import ic 
 import requests
 
 if __name__ == '__main__':
 
+    # Load Environment Variables
+    load_dotenv()
+
+    # Build and Parse Command line arguments for item/universe, which always change.
+    my_parser = argparse.ArgumentParser(description='Interested Symbol')
+    my_parser.add_argument('-i','--item', type = str, default= 'LSEG.L')
+    args = my_parser.parse_args()
+
+    universe = args.item
+
     client_secret = ''
     scope = 'trapi'
-    universe = '7203.T'
     auth_obj = None
 
-    load_dotenv()
-
     # Get RDP Token service information from Environment Variables
     base_URL = os.getenv('RDP_BASE_URL')
     auth_endpoint = base_URL + os.getenv('RDP_AUTH_URL') 
@@ -26,16 +33,17 @@
     # -- Init and Authenticate Session
     auth_request_msg = {
         'username': username ,
-	    'password': 'password' ,
+	    'password': password ,
 	    'grant_type': "password",
 	    'scope': scope,
 	    'takeExclusiveSignOnControl': "true"
     }
 
+    # Authentication with RDP Auth Service
     try:
         response = requests.post(auth_endpoint, headers = {'Accept':'application/json'}, data = auth_request_msg, auth = (app_key, client_secret))
     except Exception as exp:
-        ic('Caught exception: %s' % str(exp))
+        print('Caught exception: %s' % str(exp))
 
     if response.status_code == 200:  # HTTP Status 'OK'
         print('Authentication success')
@@ -44,6 +52,7 @@
         print('RDP authentication result failure: %s %s' % (response.status_code, response.reason))
         print('Text: %s' % (response.text))
 
+    # If authentication fail, exit program.
     if auth_obj is None:
         print('Authentication fail, exit program')
         sys.exit(0)
@@ -53,8 +62,10 @@
 
     payload = {'universe': universe}
     esg_object = None
+
+    # Request data for ESG Score Full Service
     try:
-        response = requests.get(esg_url, headers={'Authorization': 'Bearer {}'.format(auth_obj['refresh_token'])}, params = payload)
+        response = requests.get(esg_url, headers={'Authorization': 'Bearer {}'.format(auth_obj['access_token'])}, params = payload)
     except Exception as exp:
         print('Caught exception: %s' % str(exp))
 
@@ -68,6 +79,7 @@
 
     print('\n')
 
+    # If ESG Data available, convert data to Pandas DataFrame
     if esg_object is not None:
         # https://developers.refinitiv.com/en/article-catalog/article/using-rdp-api-request-esg-data-jupyter-notebook
         import pandas as pd