AmineTMIRI/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
MuslemRahimi 2024-07-23 12:14:54 +02:00
parent 01c187a91c
commit 8b8f8dd5b5
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/cron_dark_pool_flow.py
View File

@ -23,9 +23,9 @@ def save_json(data):
identifier = 'GME' identifier = 'GME'
source = 'cta_a_delayed' source = 'cta_a_delayed'
start_date, end_date = GetStartEndDate().run() #start_date, end_date = GetStartEndDate().run()
start_date = start_date.strftime("%Y-%m-%d") start_date = '2024-07-22' #start_date.strftime("%Y-%m-%d")
end_date = end_date.strftime("%Y-%m-%d") end_date = '2024-07-22' #end_date.strftime("%Y-%m-%d")
start_time = '' start_time = ''
end_time = '' end_time = ''
timezone = 'UTC' timezone = 'UTC'
@ -43,10 +43,10 @@ def get_data():
next_page = '' next_page = ''
try: try:
response = intrinio.SecurityApi().get_security_trades_by_symbol(identifier, source, start_date=start_date, start_time=start_time, end_date=end_date, end_time=end_time, timezone=timezone, page_size=page_size, darkpool_only=darkpool_only, min_size=min_size, next_page=next_page) response = intrinio.SecurityApi().get_security_trades_by_symbol(identifier, source, start_date=start_date, start_time=start_time, end_date=end_date, end_time=end_time, timezone=timezone, page_size=page_size, darkpool_only=darkpool_only, min_size=min_size, next_page=next_page)
filtered_entries = [ filtered_entries = [
entry.__dict__ for entry in response.trades entry.__dict__ for entry in response.trades
if int(entry._price * entry._total_volume) >= 2E9 #if int(entry._price * entry._total_volume) >= 2E9
] ]
data.extend(filtered_entries) data.extend(filtered_entries)