Airflow process 개발

[tofulim]

dags

• 환경변수에 한투 API key 매일 갱신해주는 dag
• 예수금이 10일에 자동이체되면 portfolio의 accum_asset을 채우는 dag
  1. 한투 API로 예수금 잔고 확인 (이체 확인)
  2. 종목별 비율에 맞게 accum_asset 채우기
     • db setting (asset update & portfolio update)
• daily로 포트폴리오 주식들의 경향을 파악하는 dag
  • 조건을 만족하는 주식이 있고 잔액이 있는 경우 buy 혹은 sell
  • (이 때 porfolio accum_asset 줄여주기)

[tofulim]

1. daily dag(00:00) - token 갱신 (db에 업로드하면 안됨..)
2. daily dag(07:40 장외 사전) - portfolio 내 종목들 확인
   • 경향 확인
   • 매수 타이밍일 때
   • 잔액(예수금) 확인 후 구매
   • 매도 타이밍일 때
   • 판매
   • 매수 & 매도에서는 portfolio의 accum_asset 금액을 차감하거나 더한다.
3. 한투 자동이체날 예수금을 accum_asset에 ratio에 맞게 분배해주는 것

[tofulim]

전제조건

모든 DAG에서 수행하는 DB작업은 HTTP request를 통해 이뤄져야 한다. 그걸 위해 FastAPI Server가 있는 것이고 asset과 portfolio table의 CRUD를 구현해 놓은 것임