|
|
|
|
@ -4,15 +4,15 @@ import os
|
|
|
|
|
|
|
|
|
|
sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '../..')))
|
|
|
|
|
|
|
|
|
|
from src.config import DATABASE_HOSTNAME, DATABASE_PORT, COLLECTOR_HOSTNAME, COLLECTOR_PORT, DATABASE_CREDENTIAL_USER, DATABASE_CREDENTIAL_PASSWORD, COLLECTOR_CREDENTIAL_USER, COLLECTOR_CREDENTIAL_PASSWORD, DATABASE_NAME, COLLECTOR_NAME
|
|
|
|
|
from src.config import DATABASE_HOSTNAME, DATABASE_PORT, COLLECTOR_HOSTNAME, COLLECTOR_PORT, _DATABASE_CREDENTIAL_USER, _DATABASE_CREDENTIAL_PASSWORD, _COLLECTOR_CREDENTIAL_USER, _COLLECTOR_CREDENTIAL_PASSWORD, DATABASE_NAME, COLLECTOR_NAME
|
|
|
|
|
|
|
|
|
|
def get_production_connection():
|
|
|
|
|
try:
|
|
|
|
|
# Konfigurasi koneksi database produksi
|
|
|
|
|
production_connection = psycopg2.connect(
|
|
|
|
|
dbname=COLLECTOR_NAME,
|
|
|
|
|
user=COLLECTOR_CREDENTIAL_USER,
|
|
|
|
|
password=COLLECTOR_CREDENTIAL_PASSWORD,
|
|
|
|
|
user=_COLLECTOR_CREDENTIAL_USER,
|
|
|
|
|
password=_COLLECTOR_CREDENTIAL_PASSWORD,
|
|
|
|
|
host=COLLECTOR_HOSTNAME,
|
|
|
|
|
port=COLLECTOR_PORT,
|
|
|
|
|
)
|
|
|
|
|
@ -34,15 +34,15 @@ def get_connection():
|
|
|
|
|
# )
|
|
|
|
|
connection = psycopg2.connect(
|
|
|
|
|
dbname=DATABASE_NAME,
|
|
|
|
|
user=DATABASE_CREDENTIAL_USER,
|
|
|
|
|
password=DATABASE_CREDENTIAL_PASSWORD,
|
|
|
|
|
user=_DATABASE_CREDENTIAL_USER,
|
|
|
|
|
password=_DATABASE_CREDENTIAL_PASSWORD,
|
|
|
|
|
host=DATABASE_HOSTNAME,
|
|
|
|
|
port=DATABASE_PORT,
|
|
|
|
|
)
|
|
|
|
|
connection_wo_db = psycopg2.connect(
|
|
|
|
|
dbname=COLLECTOR_NAME,
|
|
|
|
|
user=COLLECTOR_CREDENTIAL_USER,
|
|
|
|
|
password=COLLECTOR_CREDENTIAL_PASSWORD,
|
|
|
|
|
user=_COLLECTOR_CREDENTIAL_USER,
|
|
|
|
|
password=_COLLECTOR_CREDENTIAL_PASSWORD,
|
|
|
|
|
host=COLLECTOR_HOSTNAME,
|
|
|
|
|
port=COLLECTOR_PORT,
|
|
|
|
|
)
|
|
|
|
|
|