Apache Airflow๋ฅผ ๊ธฐ๋ฐ์ผ๋ก ํ๋ ์์ ๊ด๋ฆฌํ ์ํฌํ๋ก ์กฐ์ ์๋น์ค์ ๋๋ค.
์ ๊ท ๊ณ ๊ฐ์๊ฒ๋ ์ฒ์ 90์ผ ๋์ Composer ๋๋ ๊ธฐํ Google Cloud ์ ํ์ ์ฌ์ฉํ ์ ์๋ $300์ ๋ฌด๋ฃ ํฌ๋ ๋ง์ด ์ ๊ณต๋ฉ๋๋ค.
ํ์ด๋ธ๋ฆฌ๋ ๋ฐ ๋ฉํฐ ํด๋ผ์ฐ๋ ํ๊ฒฝ์ ์์ฐ๋ฅด๋ ํ์ดํ๋ผ์ธ์ ์์ฑ, ์ผ์ ์์ฝ, ๋ชจ๋ํฐ๋งํฉ๋๋ค.
Apache Airflow ์คํ์์ค ํ๋ก์ ํธ์ ๋น๋๋๋ฉฐ Python์ผ๋ก ์๋
์ข ์๋์ง ์๊ณ ์ฌ์ฉ์ด ๊ฐํธํฉ๋๋ค.
Apache Airflow 3(ํ๋ฆฌ๋ทฐ)์ ๋ํ ์๋ก์ด ์ง์
์ด์
Cloud Composer๋ง์ ๊ด๋ฆฌ ๊ธฐ๋ฅ๊ณผ Apache Airflow ํธํ์ฑ ๋๋ถ์ ๋ฆฌ์์ค๋ฅผ ํ๋ก๋น์ ๋ํ๊ธฐ๋ณด๋ค ์ํฌํ๋ก ์์ฑ, ์์ฝ, ๋ชจ๋ํฐ๋ง์ ์ง์คํ ์ ์์ต๋๋ค.
BigQuery, Dataflow, Dataproc, Datastore, Cloud Storage, Pub/Sub, AI Platform ๋ฑ์ Google Cloud ์ ํ๊ณผ ์๋ ํฌ ์๋ ํตํฉ์ ํตํด ์ฌ์ฉ์๋ ์์ ๋กญ๊ฒ ํ์ดํ๋ผ์ธ์ ์์ ํ ์กฐ์ ํ ์ ์์ต๋๋ค.
ํ์ดํ๋ผ์ธ์ด ์จํ๋ ๋ฏธ์ค, ์ฌ๋ฌ ํด๋ผ์ฐ๋, Google Cloud ๋ด๋ถ ๋ฑ ์ด๋์ ์์นํ๋ ๊ด๊ณ์์ด ๋จ์ผ ์กฐ์ ๋๊ตฌ๋ฅผ ํตํด ์ํฌํ๋ก๋ฅผ ์์ฑ, ์์ฝ, ๋ชจ๋ํฐ๋งํฉ๋๋ค.
์ฃผ์ ํน์ง
์จํ๋ ๋ฏธ์ค์ ํผ๋ธ๋ฆญ ํด๋ผ์ฐ๋๋ฅผ ์๋ ์ํฌํ๋ก๋ฅผ ์กฐ์ ํ์ฌ ํด๋ผ์ฐ๋๋ก์ ์ด์ ๊ณผ์ ์ ๊ฐ์ํํ๊ฑฐ๋ ํ์ด๋ธ๋ฆฌ๋ ๋ฐ์ดํฐ ํ๊ฒฝ์ ์ ์งํ์ธ์. ์ฌ๋ฌ ํด๋ผ์ฐ๋์ ๊ฑธ์ณ ๋ฐ์ดํฐ, ์ฒ๋ฆฌ, ์๋น์ค๋ฅผ ์ฐ๊ฒฐํ๋ ์ํฌํ๋ก๋ฅผ ๋ง๋ค์ด ํตํฉ๋ ๋ฐ์ดํฐ ํ๊ฒฝ์ ์ ๊ณตํฉ๋๋ค.
Cloud Composer๋ Apache Airflow๋ฅผ ๊ธฐ๋ฐ์ผ๋ก ๋น๋๋์ด ์ฌ์ฉ์์๊ฒ ํน์ ์๋น์ค์ ์ข ์๋์ง ์์ ์์ ์ ์ด๋์ฑ์ ์ ์ฌํฉ๋๋ค. Google์์๋ ์ฐธ์ฌํ๊ณ ์๋ ์ด ์คํ์์ค ํ๋ก์ ํธ๋ ๊ด๋ฒ์ํ ํ๋ซํผ๊ณผ ํตํฉ๋๋ ๊ฒ์ ๋ฌผ๋ก ๊ณ ๊ฐ์๊ฒ ํน์ ์๋น์ค์ ์ข ์๋์ง ์์ ์์ ๋ฅผ ์ค๋๋ค. ์ง์ ํ๋ซํผ์ ์๋ Airflow ์ปค๋ฎค๋ํฐ์ ์ฑ์ฅ์ ๋ฐ๋ผ ๊ณ์ ๋์ด๋ ์ ๋ง์ ๋๋ค.
Cloud Composer ํ์ดํ๋ผ์ธ์ Python์ ์ฌ์ฉํ DAG(Directed Acyclic Graph)๋ก ๊ตฌ์ฑ๋์ด ์์ด ๋ชจ๋ ์ฌ์ฉ์๊ฐ ์ฝ๊ฒ ์ฌ์ฉํ ์ ์์ต๋๋ค. ํด๋ฆญ ํ ๋ฒ์ผ๋ก ๋ฐฐํฌํ์ฌ ์ค์ ์ํฌํ๋ก์ ๋ค์ํ ์ปค๋ฅํฐ์ ์ฌ๋ฌ ๊ทธ๋ํฝ ํํ์ด ๋ค์ด ์๋ ๋ผ์ด๋ธ๋ฌ๋ฆฌ์ ์ฆ์ ์ก์ธ์คํ ์ ์์ผ๋ฏ๋ก ๋ฌธ์ ํด๊ฒฐ ๊ณผ์ ์ ๊ฐ์ํํ ์ ์์ต๋๋ค. DAG(Directed Acyclic Graph)์ ์๋ ๋๊ธฐํ ๊ธฐ๋ฅ ๋๋ถ์ ์ผ์ ์ ๋ง์ถฐ ์ ๋ฌด๋ฅผ ์ฒ๋ฆฌํ ์ ์์ต๋๋ค.
์ฃผ์ ๊ฐ์ ์ฌํญ์ผ๋ก๋ ๊ฐ์ฌ ๊ฐ๋ฅ์ฑ๊ณผ ์์ ์ ์ธ ๋กค๋ฐฑ์ ์ํ DAG ๋ฒ์ ๊ด๋ฆฌ, ๋ ๊ฐ๋จํ ๊ณผ๊ฑฐ ๋ฐ์ดํฐ ์ฌ์ฒ๋ฆฌ๋ฅผ ์ํ ์ค์ผ์ค๋ฌ ๊ด๋ฆฌ ๋ฐฑํ์ด ์์ต๋๋ค. ์๋ก์ด Task Execution API ๋ฐ SDK๋ ํฅํ ๋ค๊ตญ์ด ์ง์ ๋ฐ ๊ฒฉ๋ฆฌ๋ ์์ ํ๊ฒฝ์ ์ํ ๊ธธ์ ์ด์ด์ค๋๋ค. ์ฌ์ฉ์๋ ๊ฐ์ ๋ ํ์ ๊ธฐ๋ฅ์ ๊ฐ์ถ ๋ ๋น ๋ฅด๊ณ ํ๋์ ์ธ React ๊ธฐ๋ฐ UI๋ฅผ ํ์ฉํ ์ ์์ต๋๋ค. ๊ณํ๋ ์ด๋ฒคํธ ๊ธฐ๋ฐ ์ผ์ ์์ฝ์ ๋ณด๋ค ๋ฐ์์ฑ์ด ๋์ ๊ฑฐ์ ์ค์๊ฐ ํ์ดํ๋ผ์ธ์ ๋ชฉํ๋ก ํฉ๋๋ค. Edge Executor๋ ์๊ฒฉ ์์ ์คํ์ ์ต์ ํํ๊ณ ๋ถํ ๋ CLI(airflow/airflowctl)๋ ๊ฐ๋ฐ ๋ฐ ์ด์์ ์ํ ๋ ๋ช ํํ ๋ช ๋ น์ค ํ๊ฒฝ์ ์ ๊ณตํฉ๋๋ค.
์ฌ์ฉ ์ฌ๋ก
๋ชจ๋ ํน์ง
๋ฉํฐ ํด๋ผ์ฐ๋ | ๋ฐ์ดํฐ, ์ฒ๋ฆฌ, ์๋น์ค๋ฅผ ์ฌ๋ฌ ํด๋ผ์ฐ๋์ ๊ฑธ์ณ ์ฐ๊ฒฐํ์ฌ ํต์ผ๋ ๋ฐ์ดํฐ ํ๊ฒฝ์ ์กฐ์ฑํ๋ ์ํฌํ๋ก๋ฅผ ์์ฑํฉ๋๋ค. |
์คํ์์ค | Cloud Composer๋ Apache Airflow๋ฅผ ๊ธฐ๋ฐ์ผ๋ก ๋น๋๋์ด ์ฌ์ฉ์์๊ฒ ํน์ ์๋น์ค์ ์ข
์๋์ง ์์ ์์ ์ ์ด๋์ฑ์ ์ ์ฌํฉ๋๋ค. |
ํ์ด๋ธ๋ฆฌ๋ | ์จํ๋ ๋ฏธ์ค์ ํผ๋ธ๋ฆญ ํด๋ผ์ฐ๋๋ฅผ ์๋ ์ํฌํ๋ก๋ฅผ ์กฐ์ ํ์ฌ ํด๋ผ์ฐ๋๋ก์ ์ด์ ๊ณผ์ ์ ๊ฐ์ํํ๊ฑฐ๋ ํ์ด๋ธ๋ฆฌ๋ ๋ฐ์ดํฐ ํ๊ฒฝ์ ์ ์งํ์ธ์. |
ํตํฉ | |
Python ํ๋ก๊ทธ๋๋ฐ ์ธ์ด | ๊ธฐ์กด Python ๊ธฐ์ ์ ํ์ฉํ์ฌ Cloud Composer ๋ด์์ ์ํฌํ๋ก๋ฅผ ๋์ ์ผ๋ก ์์ฑํ๊ณ ์ํฌํ๋ก ์ผ์ ์ ์์ฝํ์ธ์. |
์์ ์ฑ | ๋ฌธ์ ์ ๊ทผ๋ณธ ์์ธ์ ๋ชจ๋ํฐ๋งํ๊ณ ํด๊ฒฐํ๋ ๊ฐํธํ ์ฐจํธ๋ฅผ ํตํด ์ํฌํ๋ก์ ์ ๋ขฐ์ฑ์ ๋์
๋๋ค. |
์์ ๊ด๋ฆฌํ | Cloud Composer๋ง์ ๊ด๋ฆฌ ๊ธฐ๋ฅ ๋๋ถ์ ๋ฆฌ์์ค๋ฅผ ํ๋ก๋น์ ๋ํ ๋๋ณด๋ค ์ํฌํ๋ก ์์ฑ, ์ผ์ ์์ฝ, ๋ชจ๋ํฐ๋ง์ ์ง์คํ ์ ์์ต๋๋ค. |
๋คํธ์ํน ๋ฐ ๋ณด์ | ํ๊ฒฝ์ ์์ฑํ๋ ๋์ Cloud Composer๋ ๋น๊ณต๊ฐ IP, ๊ณต์ VPC, VPC ์๋น์ค ์ ์ด, CMEK ์ํธํ ์ง์ ๋ฑ์ ๊ตฌ์ฑ ์ต์ ์ ์ ๊ณตํฉ๋๋ค. |
๊ฐ๊ฒฉ ์ฑ ์
Cloud Composer ์๊ธ์ ์ฌ์ฉ๋์ ๊ธฐ๋ฐ์ผ๋ก ์ฐ์ ๋๋ฏ๋ก vCPU/์๊ฐ, ์ฉ๋(GB)/์, ์ ์ก๋(GB)/์๊ณผ ๊ฐ์ ๋จ์๋ก ์ธก์ ๋ ์ฌ์ฉ๋๋งํผ๋ง ์ง๋ถํ๋ฉด ๋ฉ๋๋ค. Cloud Composer๋ ์ฌ๋ฌ Google Cloud ์ ํ์ผ๋ก ๊ตฌ์ฑ๋์ด ์๊ธฐ ๋๋ฌธ์ ๋ค์ํ ๊ฐ๊ฒฉ ์ฑ ์ ๋จ์๋ฅผ ์ฌ์ฉํฉ๋๋ค.
์๋น๋์ด๋ ์ง์์ ์ธ ์ฌ์ฉ์ ๊ด๊ณ์์ด ๊ฐ๊ฒฉ์ ๋์ผํ๊ฒ ์ ์ฉ๋ฉ๋๋ค. ์์ธํ ๋ด์ฉ์ ๊ฐ๊ฒฉ ์ฑ ์ ํ์ด์ง๋ฅผ ์ฐธ์กฐํ์ธ์.
$300์ ๋ฌด๋ฃ ํฌ๋ ๋ง๊ณผ 20์ฌ ๊ฐ์ ํญ์ ๋ฌด๋ฃ ์ ํ์ผ๋ก Google Cloud์์ ๋น๋ํ์ธ์.