aaron/trading-quant
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix bug

Browse Source
This commit is contained in:
aazhou 2023-06-17 08:24:59 +08:00
parent cb4ac50cbb
commit 639c81e446
3 changed files with 25 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
settings.py
View File

@ -17,4 +17,4 @@ oklink_api_headers = {
#whaleAlert #whaleAlert
whaleAlert_apikey='gPkElMPR8Hpe5LxjKisR4YSFzxRxMLj6' whaleAlert_apikey='gPkElMPR8Hpe5LxjKisR4YSFzxRxMLj6'
whaleAlert_max_limit = os.getenv('TQ_WHALEALERT_MAX_USD_AMOUNT',2000 * 20000) whaleAlert_max_limit = os.getenv('TQ_WHALEALERT_MAX_USD_AMOUNT',1000 * 10000)

14
strategy/large_trans.py
View File

@ -4,23 +4,31 @@ import settings
from datetime import datetime, timedelta from datetime import datetime, timedelta
import time import time
import tg import tg
import traceback
import logging
def strategy_run(): def strategy_run():
# 获取上一分钟的timestamp # 获取上一分钟的timestamp
last_min = datetime.now() - timedelta(minutes=1) last_min = datetime.now() - timedelta(minutes=5)
ts = time.mktime(last_min.timetuple()) ts = time.mktime(last_min.timetuple())
url = f'https://api.whale-alert.io/v1/transactions?api_key={settings.whaleAlert_apikey}&start={int(ts)}' url = f'https://api.whale-alert.io/v1/transactions?api_key={settings.whaleAlert_apikey}&start={int(ts)}'
resp = requests.get(url).json() resp = requests.get(url).json()
print(resp)
try:
if 'transactions' in resp:
data = resp['transactions'] data = resp['transactions']
for ts in data: for ts in data:
usd = int(ts['amount_usd']) usd = int(ts['amount_usd'])
if ts['to']['owner_type'] == 'exchange' and ts['from']['owner_type'] == 'unknown' and usd > settings.whaleAlert_max_limit: if ts['to']['owner_type'] == 'exchange' and usd > settings.whaleAlert_max_limit:
from_text = 'unknown wallet' from_text = 'unknown wallet'
content = f"🚨 {ts['amount']} #{ts['symbol']} ({ts['amount_usd']} USD) 从 {from_text} 转入 #{ts['to']['owner']}" content = f"🚨 {ts['amount']} #{ts['symbol']} ({ts['amount_usd']} USD) 从 {from_text} 转入 #{ts['to']['owner']}"
print(content) print(content)
tg.send_message(settings.chat_id, content) tg.send_message(settings.chat_id, content)
except Exception as e:
logging.error(traceback.format_exc())
tg.send_message(settings.chat_id, traceback.format_exc())

7
strategy_test.py
View File

@ -1,4 +1,9 @@
import strategy.support_resistance as sr import strategy.support_resistance as sr
import strategy.large_trans as lt
sr.strategy_run('BTCUSDT', '1h')
lt.strategy_run()
# sr.strategy_run('BTCUSDT', '1h')