34 lines
989 B
Python
34 lines
989 B
Python
|
import datetime
|
||
|
|
import os
|
||
|
|
import threading
|
||
|
|
|
||
|
|
import requests
|
||
|
|
import yfinance
|
||
|
|
|
||
|
|
|
||
|
|
def thread_function(s):
|
||
|
|
my_share_info = yfinance.Ticker(s)
|
||
|
|
my_share_data = my_share_info.info
|
||
|
|
|
||
|
|
if my_share_data['regularMarketPrice'] is not None:
|
||
|
|
payload = {
|
||
|
|
"symbol": s,
|
||
|
|
"price": float(my_share_data['regularMarketPrice']),
|
||
|
|
"time": datetime.datetime.now().strftime("%Y-%m-%dT%H:%M:%S.000Z")
|
||
|
|
}
|
||
|
|
|
||
|
|
requests.post(os.getenv("API_URL") + '/symbol', json=payload, headers={'Authorization': 'Bearer ' + token})
|
||
|
|
|
||
|
|
|
||
|
|
username = os.getenv('ADMIN_EMAIL')
|
||
|
|
password = os.getenv('ADMIN_PASSWORD')
|
||
|
|
|
||
|
|
token = requests.post(os.getenv("API_URL") + '/user/login', json={"email": username, "password": password}).json()['data']['token']
|
||
|
|
|
||
|
|
response = requests.get(os.getenv("API_URL") + '/symbols', headers={'Authorization': 'Bearer ' + token}).json()['data']
|
||
|
|
|
||
|
|
for symbol in response:
|
||
|
|
x = threading.Thread(target=thread_function, args=(symbol,))
|
||
|
|
x.start()
|
||
|
|
|