bishwajeet.rajak/ach_ui_dbtl_file_based
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

changed config to prod, and fetching only today's files from SFTP

Browse Source
This commit is contained in:
Md Asif
2026-02-11 14:20:12 +05:30
parent 81ad34fd65
commit 2e07dcc96a
5 changed files with 14 additions and 270 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
config.py
View File

@@ -30,18 +30,18 @@ class Config:
"""Load database configuration."""
self.db_user = os.getenv('DB_USER', 'pacs_db')
self.db_password = os.getenv('DB_PASSWORD', 'pacs_db')
self.db_host = os.getenv('DB_HOST', 'testipksdb.c7q7defafeea.ap-south-1.rds.amazonaws.com')
self.db_host = os.getenv('DB_HOST', 'ipksprod3.c7q7defafeea.ap-south-1.rds.amazonaws.com')
self.db_port = int(os.getenv('DB_PORT', '1521'))
self.db_service_name = os.getenv('DB_SERVICE_NAME', 'IPKSDB')
self.db_service_name = os.getenv('DB_SERVICE_NAME', 'IPKS')
self.db_pool_min = int(os.getenv('DB_POOL_MIN', '2'))
self.db_pool_max = int(os.getenv('DB_POOL_MAX', '10'))
def _load_sftp_config(self):
"""Load SFTP configuration."""
self.sftp_host = os.getenv('SFTP_HOST', 'localhost')
self.sftp_port = int(os.getenv('SFTP_PORT', '22'))
self.sftp_username = os.getenv('SFTP_USERNAME', 'ipks')
self.sftp_password = os.getenv('SFTP_PASSWORD', '')
self.sftp_host = os.getenv('SFTP_HOST', '142.79.249.123')
self.sftp_port = int(os.getenv('SFTP_PORT', '4650'))
self.sftp_username = os.getenv('SFTP_USERNAME', 'ipkssftp')
self.sftp_password = os.getenv('SFTP_PASSWORD', 'Wnb10U11BE7N26')
self.sftp_base_path = os.getenv('SFTP_BASE_PATH', '/home/ipks/IPKS_FILES/REPORTS')
def _load_processing_config(self):
@@ -53,7 +53,7 @@ class Config:
def _parse_bank_codes(self):
"""Parse bank codes from comma-separated environment variable."""
codes_str = os.getenv('BANK_CODES', '0015,0002')
codes_str = os.getenv('BANK_CODES', '0001,0002,0003,0004,0005,0006,0007,0009,0012,0013,0014,0015,0016,0017,0018,0020,0021')
return [code.strip() for code in codes_str.split(',') if code.strip()]
def get_db_connection_string(self):