|
@@ -1,9 +1,9 @@
|
|
|
-from connect import DataConsumer
|
|
|
-
|
|
|
-credentials = "host=localhost dbname=logistics user=postgres password=postgres_password"
|
|
|
+from consumer.connect import DataConsumer
|
|
|
+from consumer.credentials import getCredentials
|
|
|
|
|
|
print('Start')
|
|
|
|
|
|
+credentials = getCredentials()
|
|
|
consumer = DataConsumer(credentials)
|
|
|
|
|
|
rows = consumer.getProductSet()
|
|
@@ -11,4 +11,4 @@ rows = consumer.getProductSet()
|
|
|
for r in rows:
|
|
|
print(r)
|
|
|
|
|
|
-print('End')
|
|
|
+print('End')
|