· 8 years ago · Feb 10, 2018, 09:58 AM
1from time import localtime, sleep, strftime
2
3from binance.client import Client
4from binance.exceptions import BinanceAPIException
5
6import psycopg2.extras
7
8
9API_KEY = '<API_KEY>'
10API_SECRET = '<API_SECRET>'
11
12# How often the data should be gathered (in seconds)
13DATA_GATHERING_SLEEP = 5
14
15# The percentage (%) that sets when the user should be announced of a change
16PERCENTAGE_THRESHOLD = 3.00
17
18DB_NAME = 'binance'
19DB_USER = 'postgres'
20DB_PASS = 'postgres'
21
22
23class Colors:
24 GREEN = ' 33[92m'
25 WARNING = ' 33[93m'
26 END = ' 33[0m'
27
28
29class BinanceStockerProcessor:
30
31 def __init__(self):
32 try:
33 self.client = Client(API_KEY, API_SECRET)
34 except BinanceAPIException as e:
35 print(e)
36
37 self.db_connection = psycopg2.connect(database=DB_NAME, user=DB_USER, password=DB_PASS)
38 self.db_cursor = self.db_connection.cursor(cursor_factory=psycopg2.extras.DictCursor)
39
40 self.tickers = self.client.get_all_tickers()
41
42 def calculate_percentage(self):
43
44 for ticker in self.tickers:
45 now = strftime("%Y-%m-%d %H:%M:%S", localtime())
46
47 # write currencies to DB
48 self.db_cursor.execute("""
49 INSERT INTO binance (date, symbol, price)
50 VALUES (%s,%s,%s)
51 """, (now, ticker['symbol'], ticker['price']))
52 self.db_connection.commit()
53
54 # get data from db
55 self.db_cursor.execute("""
56 SELECT * FROM binance
57 WHERE symbol=%s
58 ORDER BY date DESC LIMIT 1
59 """, (ticker['symbol'].upper(),))
60
61 rows_now = self.db_cursor.fetchall()
62
63 self.db_cursor.execute("""
64 SELECT * FROM binance
65 WHERE symbol=%s
66 AND date >= NOW() AT TIME ZONE 'EET' - INTERVAL '15 seconds'
67 ORDER BY date ASC
68 """, (ticker['symbol'].upper(),))
69
70 rows_10s = self.db_cursor.fetchall()
71
72 self.db_cursor.execute("""
73 SELECT * FROM binance
74 WHERE symbol=%s
75 AND date >= NOW() AT TIME ZONE 'EET' - INTERVAL '1 minutes'
76 ORDER BY date ASC
77 """, (ticker['symbol'].upper(),))
78
79 rows_1min = self.db_cursor.fetchall()
80
81 self.db_cursor.execute("""
82 SELECT * FROM binance
83 WHERE symbol=%s
84 AND date >= NOW() AT TIME ZONE 'EET' - INTERVAL '5 minutes'
85 ORDER BY date ASC
86 """, (ticker['symbol'].upper(),))
87
88 rows_5min = self.db_cursor.fetchall()
89
90 date_now, symbol_now, price_now = self.get_rows_data(rows_now)
91 date_10s, symbol_10s, price_10s = self.get_rows_data(rows_10s)
92 date_1min, symbol_1min, price_1min = self.get_rows_data(rows_1min)
93 date_5min, symbol_5min, price_5min = self.get_rows_data(rows_5min)
94
95 percentage_10s = self.get_percentage(price_now, price_10s)
96 percentage_1min = self.get_percentage(price_now, price_1min)
97 percentage_5min = self.get_percentage(price_now, price_5min)
98
99 if percentage_5min >= PERCENTAGE_THRESHOLD:
100 value = (f"{Colors.WARNING}{ticker['symbol'].upper()}{Colors.END}: "
101 f"{Colors.GREEN}{percentage_5min}%{Colors.END} (5min) | "
102 f"{Colors.GREEN}{percentage_1min}%{Colors.END} (1min) | "
103 f"{Colors.GREEN}{percentage_10s}%{Colors.END} (10s)")
104
105 print(value)
106
107 @staticmethod
108 def get_percentage(now, old):
109 if now == old:
110 return 0
111
112 try:
113 return ((now - old) / old) * 100.0
114 except ZeroDivisionError:
115 return 0
116
117 @staticmethod
118 def get_rows_data(data):
119 if len(data) >= 1:
120 return data[0][0], data[0][1], data[0][2]
121 else:
122 print('Error here! Will exit now...')
123 return
124
125
126def main():
127 while True:
128 binance = BinanceStockerProcessor()
129 binance.calculate_percentage()
130 sleep(DATA_GATHERING_SLEEP)
131
132
133if __name__ == '__main__':
134 try:
135 main()
136 except KeyboardInterrupt:
137 print('Exiting now...')
138
139python-binance==0.5.11
140psycopg2==2.7.3.2
141
142pip install -r requirements.txt
143
144CREATE DATABASE binance;
145
146CREATE TABLE IF NOT EXISTS binance (
147 date TIMESTAMP,
148 symbol VARCHAR(20),
149 price REAL
150)