43 lines
1.1 KiB
Python
43 lines
1.1 KiB
Python
|
|
import asyncio
|
|
import os
|
|
from datetime import datetime
|
|
import asyncpg
|
|
|
|
DB_HOST = os.getenv('DB_HOST', 'localhost')
|
|
DB_PORT = int(os.getenv('DB_PORT', 5432))
|
|
DB_NAME = os.getenv('DB_NAME', 'btc_data')
|
|
DB_USER = os.getenv('DB_USER', 'btc_bot')
|
|
DB_PASSWORD = os.getenv('DB_PASSWORD', '')
|
|
|
|
async def check_data():
|
|
conn = await asyncpg.connect(
|
|
host=DB_HOST,
|
|
port=DB_PORT,
|
|
database=DB_NAME,
|
|
user=DB_USER,
|
|
password=DB_PASSWORD
|
|
)
|
|
|
|
try:
|
|
print("Checking candle counts...")
|
|
rows = await conn.fetch("""
|
|
SELECT interval, COUNT(*), MIN(time), MAX(time)
|
|
FROM candles
|
|
GROUP BY interval
|
|
ORDER BY interval
|
|
""")
|
|
|
|
for row in rows:
|
|
print(f"Interval: {row['interval']}")
|
|
print(f" Count: {row['count']}")
|
|
print(f" Min Time: {row['min']}")
|
|
print(f" Max Time: {row['max']}")
|
|
print("-" * 20)
|
|
|
|
finally:
|
|
await conn.close()
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(check_data())
|