-
Notifications
You must be signed in to change notification settings - Fork 0
/
get_data.py
28 lines (18 loc) · 1.26 KB
/
get_data.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
from sqlalchemy import create_engine, text
import pandas as pd
engine = create_engine("postgresql://fgvqsuuw:fziWIx4G-xu3bPvFa4zVSo1TIPZf7Vyc@mel.db.elephantsql.com/fgvqsuuw")
class Ticker:
def __init__(self, ticker) -> None:
self.ticker = ticker
def get_ticker_info(self):
return pd.read_sql_query(sql=text(f"SELECT * FROM tiker_info WHERE secid = '{self.ticker}'"), con=engine.connect())
def get_history_ticker_hour(self):
return pd.read_sql_query(sql=text(f"SELECT * FROM history_tiker_hour WHERE secid = '{self.ticker}'"), con=engine.connect())
def get_history_ticker_day(self):
return pd.read_sql_query(sql=text(f"SELECT * FROM history_tiker_day WHERE secid = '{self.ticker}'"), con=engine.connect())
def get_history_ticker_week(self):
return pd.read_sql_query(sql=text(f"SELECT * FROM history_tiker_week WHERE secid = '{self.ticker}'"), con=engine.connect())
def get_history_ticker_month(self):
return pd.read_sql_query(sql=text(f"SELECT * FROM history_tiker_month WHERE secid = '{self.ticker}'"), con=engine.connect())
def get_history_ticker_quarter(self):
return pd.read_sql_query(sql=text(f"SELECT * FROM history_tiker_quarter WHERE secid = '{self.ticker}'"), con=engine.connect())