Update push_data_postgres

push_data_postgres/push_data_postgres

@@ -8,6 +8,9 @@ from pathlib import Path
 from sqlalchemy import create_engine
 import io
 import logging
+from ilens_sdk import Component
+from ilens_sdk import logger
+
 
 postgres_database = os.environ.get('postgres_database', default='ilens_jubilant')
 postgre_user = os.environ.get('postgre_user', default='ilens')
@@ -127,6 +130,16 @@ class PushDataToPostgres():
         except Exception as e:
             print(f'Failed to ingest Data:{str(e)}')
 
+class PushPostgres(Component):
+    def __init__(self):
+        logger.info("starting component")
+        super().__init__()
+
+    def run(self):
+        push_data_postgres = PushDataToPostgres()
+        push_data_postgres.push_postgres()
+
 
-push_data_postgres = PushDataToPostgres()
-push_data_postgres.push_postgres()
+if __name__ == "__main__":
+   object = PushPostgres()
+   object.start()