Valantis Hatzimagkas
03/03/2022, 10:08 AMAbhishek
03/03/2022, 10:11 AMValantis Hatzimagkas
03/03/2022, 10:19 AMfrom prefect import task, Flow, prefect
from prefect.storage import Docker
import requests
lat = 40
lon = 45
API_key = 'my_key'
url = f'<https://api.openweathermap.org/data/2.5/weather?lat={lat}&lon={lon}&appid={API_key}>'
@task
def get_weather():
    return requests.get(url).json()
@task
def logger(res):
    for k, v in res['main'].items():
        print(f'{k}: {v}')
with Flow('spray_service') as flow:
    data = get_weather()
    logger(data)
if __name__ == "__main__":
    flow.storage = Docker(image_name="my_image", image_tag="latest", local_image=True,
                          dockerfile='Dockerfile')
    #flow.register('test')
    flow.run()Anna Geller
Anna Geller
Valantis Hatzimagkas
03/03/2022, 11:31 AMValantis Hatzimagkas
03/03/2022, 3:30 PMFROM prefecthq/prefect:0.15.13-python3.9Anna Geller
