40 lines
1.2 KiB
Python
40 lines
1.2 KiB
Python
|
|
import os
|
|
import psycopg2
|
|
import logging
|
|
from datetime import datetime
|
|
|
|
# Config logging
|
|
logging.basicConfig(level=logging.INFO)
|
|
|
|
def inspect_db():
|
|
db_host = os.getenv("DB_HOST", "192.168.3.195")
|
|
db_user = os.getenv("DB_USER", "value")
|
|
db_pass = os.getenv("DB_PASSWORD", "Value609!")
|
|
db_name = os.getenv("DB_NAME", "fa3")
|
|
|
|
conn = psycopg2.connect(
|
|
host=db_host, user=db_user, password=db_pass, dbname=db_name
|
|
)
|
|
|
|
with conn.cursor() as cur:
|
|
# Check basic data market cap
|
|
cur.execute("""
|
|
SELECT update_date, indicator, value, value_date, currency, source
|
|
FROM stockcard
|
|
WHERE Company_code LIKE '6301 JP%'
|
|
AND (indicator = 'market_cap' OR indicator = 'Market_Cap')
|
|
ORDER BY update_date DESC, value_date DESC
|
|
LIMIT 20;
|
|
""")
|
|
rows = cur.fetchall()
|
|
print(f"{'Update Date':<20} | {'Indicator':<15} | {'Currency':<5} | {'Value Date':<12} | {'Value (Raw)':<20} | {'Source'}")
|
|
print("-" * 100)
|
|
for row in rows:
|
|
print(f"{str(row[0]):<20} | {row[1]:<15} | {row[4]:<5} | {str(row[3]):<12} | {row[2]:<20} | {row[5]}")
|
|
|
|
conn.close()
|
|
|
|
if __name__ == "__main__":
|
|
inspect_db()
|