aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/extract_lambda.py32
-rw-r--r--src/load_lambda.py0
-rw-r--r--src/transform_lambda.py0
3 files changed, 32 insertions, 0 deletions
diff --git a/src/extract_lambda.py b/src/extract_lambda.py
new file mode 100644
index 0000000..7d56c66
--- /dev/null
+++ b/src/extract_lambda.py
@@ -0,0 +1,32 @@
+from pg8000.native import Connection, Error, DatabaseError, InterfaceError
+from dotenv import load_dotenv
+import os
+
+load_dotenv()
+
+def extract():
+
+# temporary credentials for dev- will not have access when uploaded
+
+ database = os.getenv('database')
+ user = os.getenv('user')
+ password = os.getenv('password')
+ host = os.getenv('host')
+ port = os.getenv('port')
+
+
+ try:
+ db = Connection.run(
+ database=database,
+ user=user,
+ password=password,
+ host=host,
+ port=port
+ )
+ except DatabaseError as e:
+ print(e)
+ except InterfaceError as i:
+ print(i)
+
+
+ \ No newline at end of file
diff --git a/src/load_lambda.py b/src/load_lambda.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/src/load_lambda.py
diff --git a/src/transform_lambda.py b/src/transform_lambda.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/src/transform_lambda.py
git.ajschof.me — hosted by ajschofield — powered by cgit