Changed client config to client_logs
This commit is contained in:
@@ -106,7 +106,7 @@ def get_client_names():
|
||||
cursor = conn.cursor()
|
||||
|
||||
# Query to get client names and their s3_paths
|
||||
query = "SELECT DISTINCT client_name, s3_bucket_path FROM STG.CLIENT_CONFIG"
|
||||
query = "SELECT DISTINCT client_name, bucket_name FROM STG.CLIENT_LOGS"
|
||||
cursor.execute(query)
|
||||
# Create 2 lists from the query results
|
||||
client_names = []
|
||||
@@ -114,7 +114,7 @@ def get_client_names():
|
||||
|
||||
for row in cursor:
|
||||
client_names.append(row[0])
|
||||
s3_paths.append(row[1].replace('s3://','').split('/')[0]) # Extracting the bucket name from the s3 path
|
||||
s3_paths.append(row[1]) # Extracting the bucket name from the s3 path
|
||||
cursor.close()
|
||||
conn.close()
|
||||
return client_names, s3_paths
|
||||
|
||||
Reference in New Issue
Block a user