SQL

dbtestcall.py

@@ -0,0 +1,20 @@
+import math
+import pg8000.native
+
+def Main():
+    # con = pg8000.native.Connection('postgres', password='postgres', host='localhost', port=5432, database='da11copy')
+    con = pg8000.native.Connection('query_user', password='Udoz4nahbeethohb', host='localhost', port=5432, database='da11copy')
+    result = con.run(
+        """
+        SELECT
+            signature, RTRIM(NULLIF(errors, '')) as errors,
+            is_executed, is_confirmed,
+            cu_requested, prioritization_fees
+        FROM banking_stage_results.transaction_infos
+        """)
+    for row in result:
+        print(row)
+
+if __name__=="__main__":
+    Main()
+

requirements.txt

@@ -5,4 +5,5 @@ gunicorn==20.1.0
 itsdangerous==2.1.2
 Jinja2==3.1.2
 MarkupSafe==2.1.2
+pg8000==1.30.2
 Werkzeug==2.3.3