Prefect2
อันนี้อีกตัวที่ว่าน่าสนใจ เทสมันทั้งสองตัวนี้ละ dagster กับ prefect เพราะตัวนี้ก็เพิ่งออกเวอร์ชั่น 2 มาเมื่อไม่นานนี้เอง เผื่อว่าการเปลี่ยนแปลงจะมีอะไรน่าสนเพิ่มขึ้น
- pip install -U prefect
- sudo apt install git
- git clone https://github.com/PrefectHQ/prefect.git
- cd prefect
- pip install -e ".[dev]"
- pre-commit install
- prefect version
- สร้างไฟล์ prefect_01.py ใส่โค้ด
from prefect import flow, task
@task(retries=3) #ให้มันลองใหม่ 3 ครั้งถ้ามีปัญหา
def job01():
print("Hi!! I am Prefect2")
@task
def job02():
print("job work end")
@flow
def flow01():
job01()
@flow
def flow02():
job01()
job02()
flow01()
flow02()
- python3 prefect_01.py สั่งรัน
- prefect orion start สั่งรันเซิฟเวอร์ โดย default จะเป็น url http://127.0.0.1:4200 นะครับ เป็น uvicorn
ปล. หากสนใจตัวอย่างอื่นๆ ลองดูที่เว็บนี้นะครับ
ความคิดเห็น
แสดงความคิดเห็น