Workflows์ Cloud Composer๋ ์๋น์ค๋ฅผ ๊ฒฐํฉํ์ฌ ์ ํ๋ฆฌ์ผ์ด์ ๊ธฐ๋ฅ์ ๊ตฌํํ๊ฑฐ๋ ๋ฐ์ดํฐ ์ฒ๋ฆฌ๋ฅผ ์ํํ๊ธฐ ์ํ ์๋น์ค ์กฐ์ ์ ๋ ๋ค ์ฌ์ฉํ ์ ์์ต๋๋ค. ๋์ ๊ฐ๋ ์ ์ ์ฌํ์ง๋ง, ๊ฐ๊ธฐ ๋ค๋ฅธ ์ฌ์ฉ ์ฌ๋ก์ ๋ง๊ฒ ์ค๊ณ๋์์ต๋๋ค. ์ด ํ์ด์ง๋ ์ฌ์ฉ์์ ์ฌ์ฉ ์ฌ๋ก์ ์ ํฉํ ์ ํ์ ์ ํํ๋ ๋ฐ ๋์์ด ๋ฉ๋๋ค.
์ฃผ์ ์ฐจ์ด์
Workflows์ Cloud Composer์ ์ฃผ๋ ์ฐจ์ด๋ ๊ฐ ์ ํ์ด ์ง์ํ๋๋ก ์ค๊ณ๋ ์ํคํ ์ฒ ์ ํ์ ์์ต๋๋ค.
Workflows๋ ์ฌ๋ฌ HTTP ๊ธฐ๋ฐ ์๋น์ค๋ฅผ ๋ด๊ตฌ์ฑ์ด ์ฐ์ํ ์คํ ์ดํธํ(Stateful) ์ํฌํ๋ก๋ก ์กฐ์ ํฉ๋๋ค. ์ง์ฐ ์๊ฐ์ด ๋ฎ๊ณ ๋ง์ ์คํ ์์ ์ ์ฒ๋ฆฌํ ์ ์์ต๋๋ค. ๋ํ ์์ ํ ์๋ฒ๋ฆฌ์ค์ ๋๋ค.
Workflows๋ ๋ง์ดํฌ๋ก์๋น์ค๋ฅผ ํ๋๋ก ์ฐ๊ฒฐํ์ฌ VM ์์ ๋๋ ์ค์ง ๊ทธ๋ฆฌ๊ณ ์ธ๋ถ ์์คํ ๊ณผ์ ํตํฉ ๊ณผ ๊ฐ์ ์ธํ๋ผ ํ์คํฌ๋ฅผ ์๋ํํ๋ ๋ฐ ์ ์ฉํฉ๋๋ค. Workflows ์ปค๋ฅํฐ๋ ๋ํ Cloud Storage ๋ฐ BigQuery์ ๊ฐ์ Google Cloud ์๋น์ค์์ ๊ฐ๋จํ ์์ ์ํ์ค๋ฅผ ์ง์ํฉ๋๋ค.
Cloud Composer๋ ๋ฐ์ดํฐ ๊ธฐ๋ฐ ์ํฌํ๋ก(ํนํ ETL/ELT)๋ฅผ ์กฐ์ ํ๋๋ก ์ค๊ณ๋์์ต๋๋ค. Apache Airflow ํ๋ก์ ํธ๋ฅผ ๊ธฐ๋ฐ์ผ๋ก ๋น๋๋์์ง๋ง Cloud Composer๋ ์์ ๊ด๋ฆฌํ์ ๋๋ค. Cloud Composer๋ ์จํ๋ ๋ฏธ์ค ๋๋ ๊ต์ฐจ ๋ค์ค ํด๋ผ์ฐ๋ ํ๋ซํผ์ ํฌํจํ์ฌ ์์น์ ๊ด๊ณ์์ด ํ์ดํ๋ผ์ธ์ ์ง์ํฉ๋๋ค. ํ์คํฌ ๋ฐ ์์ฝ์ ํฌํจํ์ฌ Cloud Composer์ ๋ชจ๋ ๋ ผ๋ฆฌ๋ Python์์ ๋ฐฉํฅ์ฑ ๋น์ํ ๊ทธ๋ํ(DAG) ์ ์ ํ์ผ๋ก ํํ๋ฉ๋๋ค.
Cloud Composer๋ ํ์คํฌ ์คํ ์ฌ์ด์ ๋ช ์ด ์ ๋์ ์ง์ฐ ์๊ฐ์ ์ฒ๋ฆฌํ ์ ์๋ ์ผ๊ด ์ํฌ๋ก๋์ ์ ํฉํฉ๋๋ค. Cloud Composer๋ฅผ ์ฌ์ฉํ๋ฉด BigQuery์์ ์์ ์ ํธ๋ฆฌ๊ฑฐํ๊ฑฐ๋ Dataflow ํ์ดํ๋ผ์ธ์ ์์ํ๋ ๋ฑ ๋ฐ์ดํฐ ํ์ดํ๋ผ์ธ์์ ์๋น์ค๋ฅผ ์กฐ์ ํ ์ ์์ต๋๋ค. ๊ธฐ์กด ์ฐ์ฐ์๋ฅผ ์ฌ์ฉํ์ฌ ๋ค์ํ ์๋น์ค์ ํต์ ํ ์ ์์ผ๋ฉฐ Google Cloud ์๋ง 150๊ฐ ์ด์์ ์ฐ์ฐ์๊ฐ ์์ต๋๋ค.
์์ธํ ๊ธฐ๋ฅ ๋น๊ต
ํน์ฑ | Workflows | Cloud Composer |
---|---|---|
๊ตฌ๋ฌธ | YAML ๋๋ JSON ํ์์ Workflows ๊ตฌ๋ฌธ | Python |
์ํ ๋ชจ๋ธ | ๋ช ๋ น์ ํ๋ฆ ์ ์ด | ์๋ ์ข ์ ํญ๋ชฉ์ ๊ฐ์ง๋ ์ ์ธ์ DAG |
ํตํฉ | HTTP ์์ฒญ ๋ฐ ์ปค๋ฅํฐ | Airflow ์ฐ์ฐ์ ๋ฐ ์ผ์ |
๋จ๊ณ ๊ฐ ๋ฐ์ดํฐ ์ ๋ฌ | ๋ณ์์ฉ 512KB | XCom์ฉ 48KB1 |
์คํ ํธ๋ฆฌ๊ฑฐ ๋ฐ ์์ฝ | gcloud CLI, Google Cloud ์ฝ์, Workflows API, Workflows ํด๋ผ์ด์ธํธ ๋ผ์ด๋ธ๋ฌ๋ฆฌ, Cloud Scheduler | Airflow Sensor, DAG ์ ์ ํ์ผ์ ํฌ๋ก ๊ณผ ์ ์ฌํ ์ผ์ |
๋น๋๊ธฐ ํจํด |
|
Polling |
๋์ ์คํ | ๋์ผํ ์ํฌํ๋ก์ ๋์ ์คํ ๋๋ ๋์ ๋จ๊ณ๋ฅผ ์ฌ์ฉํ๋ ์ํฌํ๋ก ๋ด๋ถ์ ๋์ ์คํ | ์ข ์ ํญ๋ชฉ ๊ธฐ๋ฐ ์๋ ์ํ |
์คํ ์ง์ฐ ์๊ฐ | ๋ฐ๋ฆฌ์ด | ์ด |
์คํ์์ค ๊ธฐ๋ฐ | ์๋์ | ์(Apache Airflow) |
ํ์ฅ ๋ชจ๋ธ | ์๋ฒ๋ฆฌ์ค(์์์ ๋ฐ๋ผ ํ์ฅ๋๊ณ 0์ผ๋ก ์ถ์) | ํ๋ก๋น์ ๋๋จ |
์ฒญ๊ตฌ ๋ชจ๋ธ | ์ฌ์ฉ๋ ๊ธฐ๋ฐ(์คํ ๋จ๊ณ๋น) | ํ๋ก๋น์ ๋ ์ฉ๋ ๊ธฐ๋ฐ |
๋ฐ์ดํฐ ์ฒ๋ฆฌ ๊ธฐ๋ฅ | ์๋์ | ๋ฐฑํ, DAG ์ฌ์คํ ๊ธฐ๋ฅ |
-
airflow.models.xcom ์์ค ์ฝ๋. Apache Airflow ๋ฌธ์. 2021๋ 8์ 2์ผ. โฉ