update similar stocks
This commit is contained in:
parent
c1139bcad0
commit
c3e696e1ca
@ -26,12 +26,16 @@ query_template = """
|
|||||||
|
|
||||||
async def get_data(symbol):
|
async def get_data(symbol):
|
||||||
"""Extract specified columns data for a given symbol."""
|
"""Extract specified columns data for a given symbol."""
|
||||||
columns = ['dividendYield', 'employees', 'marketCap','relativeFTD']
|
columns = ['dividendYield', 'employees', 'marketCap','relativeFTD','name']
|
||||||
|
|
||||||
if symbol in stock_screener_data_dict:
|
if symbol in stock_screener_data_dict:
|
||||||
result = {}
|
result = {}
|
||||||
for column in columns:
|
for column in columns:
|
||||||
|
try:
|
||||||
result[column] = stock_screener_data_dict[symbol].get(column, None)
|
result[column] = stock_screener_data_dict[symbol].get(column, None)
|
||||||
|
|
||||||
|
except:
|
||||||
|
pass
|
||||||
return result
|
return result
|
||||||
return {}
|
return {}
|
||||||
|
|
||||||
@ -48,7 +52,6 @@ async def run():
|
|||||||
try:
|
try:
|
||||||
# Get the list of peer stocks
|
# Get the list of peer stocks
|
||||||
peers = orjson.loads(df['stock_peers'].iloc[0])
|
peers = orjson.loads(df['stock_peers'].iloc[0])
|
||||||
|
|
||||||
# Create a list to store peer data
|
# Create a list to store peer data
|
||||||
peer_data_list = []
|
peer_data_list = []
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user