|
|
|
@ -89,7 +89,7 @@ def find_pce(date:str): |
|
|
|
|
try: |
|
|
|
|
driver.get(pce_url+date) |
|
|
|
|
print("Successfully accessed the website.") |
|
|
|
|
time.sleep(0.5) |
|
|
|
|
time.sleep(1) |
|
|
|
|
date = driver.find_element(By.XPATH, '//*[@id="home"]/h1').text.split(' ')[4] |
|
|
|
|
value_1 = driver.find_element(By.XPATH, '//*[@id="home"]/div[2]/div/div/p[2]').text |
|
|
|
|
value_2 = driver.find_element(By.XPATH, '//*[@id="home"]/div[2]/div/div/div[1]/table/tbody/tr[13]').text.strip(' ').split(' ')[-1] |
|
|
|
@ -161,11 +161,11 @@ def broadcast_all_cpi(target:str): |
|
|
|
|
"-1002033782195") |
|
|
|
|
broadcast_message(f"The above is the CPI for {target}","-1002033782195") |
|
|
|
|
return True |
|
|
|
|
def broadcast_all_fomc(target:str): |
|
|
|
|
def broadcast_all_fomc(target:str,date_target:str): #date_target = "20240131a" |
|
|
|
|
startimee = time.time() |
|
|
|
|
date , message = find_fomc(fomc_url,'20240131a') |
|
|
|
|
date , message = find_fomc(fomc_url,date_target) |
|
|
|
|
while date != target: |
|
|
|
|
date, message = find_fomc(fomc_url,'20240131a') |
|
|
|
|
date, message = find_fomc(fomc_url,date_target) |
|
|
|
|
broadcast_message(message, "-1002033782195") |
|
|
|
|
endtimee = time.time() |
|
|
|
|
broadcast_message( |
|
|
|
@ -197,26 +197,30 @@ def wrapper_function_pce(target,date_target): |
|
|
|
|
result = broadcast_all_pce(target,date_target) |
|
|
|
|
if result: |
|
|
|
|
has_broadcasted = True |
|
|
|
|
def wrapper_function_fomc(target,date_target): |
|
|
|
|
global has_broadcasted |
|
|
|
|
result = broadcast_all_fomc(target,date_target=date_target) |
|
|
|
|
if result: |
|
|
|
|
has_broadcasted = True |
|
|
|
|
if __name__ == "__main__": |
|
|
|
|
global nonfarm_url , cpi_url , fomc_url , pce_url |
|
|
|
|
nonfarm_url = "https://www.bls.gov/news.release/empsit.nr0.htm" |
|
|
|
|
cpi_url = "https://www.bls.gov/news.release/cpi.nr0.htm" |
|
|
|
|
fomc_url = "https://www.federalreserve.gov/newsevents/pressreleases/monetary" |
|
|
|
|
pce_url = "https://www.bea.gov/news/2024/personal-income-and-outlays-"#january-2024 |
|
|
|
|
# broadcast_all_pce("February", "february-2024") |
|
|
|
|
|
|
|
|
|
print("Start Time:" , datetime.fromtimestamp(time.time())) |
|
|
|
|
''' |
|
|
|
|
schedule.every().day.at("10:44").do(wrapper_function_pce, "February", "february-2024") |
|
|
|
|
|
|
|
|
|
schedule.every().day.at("10:44").do(wrapper_function_fomc, "March", "20240320a") |
|
|
|
|
|
|
|
|
|
while True: |
|
|
|
|
if datetime.now().strftime("%Y-%m-%d %H:%M") == "2024-04-23 10:44": |
|
|
|
|
if datetime.now().strftime("%Y-%m-%d %H:%M") == "2024-05-01 23:32": |
|
|
|
|
schedule.run_pending() |
|
|
|
|
if has_broadcasted: |
|
|
|
|
print("Broadcast completed") |
|
|
|
|
break |
|
|
|
|
time.sleep(0.1) # Check every 0.1 seconds |
|
|
|
|
''' |
|
|
|
|
|
|
|
|
|
#NonFarm |
|
|
|
|
# date , message = find_non_farm(nonfarm_url) |
|
|
|
|
# print(date) |
|
|
|
@ -226,7 +230,12 @@ if __name__ == "__main__": |
|
|
|
|
|
|
|
|
|
#PCE |
|
|
|
|
#broadcast_all_pce("February", "february-2024") |
|
|
|
|
date, message1, message2 = find_pce("february-2024") |
|
|
|
|
print(date) |
|
|
|
|
print(message1) |
|
|
|
|
print(message2) |
|
|
|
|
# date, message1, message2 = find_pce("february-2024") |
|
|
|
|
# print(date) |
|
|
|
|
# print(message1) |
|
|
|
|
# print(message2) |
|
|
|
|
|
|
|
|
|
#FOMC |
|
|
|
|
# date , message = find_fomc(fomc_url,"20240320a") |
|
|
|
|
# print(date) |
|
|
|
|
# print(message) |