11์ ์ด๋ถํฐ 12์ ๋ง๊น์ง ์ฐ์ํ ์คํฐ๋์ ์ฐธ๊ฐํ์ฌ Dask์ Ray์ ๋ํด ์์๋ณผ ์ ์์์ต๋๋ค. ํ์ ์
๋ฌด๋ฅผ ํ๋ฉด์ ๊ธฐ์ ์ ์ธ ์ด๋ ค์์ด ์์ด๋ ๋ด๋ถ์ ์ผ๋ก ํด๊ฒฐ์ด ์ด๋ ค์ธ ๋๊ฐ ์์์ต๋๋ค. ๊ทธ๋ด ๋ ๋ง๋ค ๋ค๋ฅธ ํ์ฌ์์๋ ์ด๋ป๊ฒ ์ด๋ฌํ ๋ฌธ์ ๋ค์ ํด๊ฒฐํ๋์ง ๊ถ๊ธ์ฆ์ด ์์์ต๋๋ค. ์ด์ธ์๋ ๋ค๋ฅธ ์ฐ์
๊ตฐ์ด๋ ์๋น์ค์์๋ ์ด๋ป๊ฒ ๋ฐ์ดํฐ๋ฅผ ํ์ฉํ๊ณ ์ด๋ ค์๋ค์ ํด๊ฒฐํ๋์ง ๋ค์ด๋ณด๊ณ ์ถ๋ค๊ณ ์๊ฐํ๋๋ฐ ๊ธฐํ๊ฐ ๋์ด ์คํฐ๋์ ์ฐธ์ฌํ ์ ์์์ต๋๋ค.
์
๋ฌด๋ฅผ ์ํํ๋ฉด์ ๋์ฉ๋ parquet ํ์ผ์ ์ฝ๊ณ pandas๋ก ๋ณํํ ๋ ๋ฉ๋ชจ๋ฆฌ ์๋ฌ๋ฅผ ๊ฒฝํํ ์ ์ด ์์ต๋๋ค. 'pyspark to_pandas memory error' ๋ผ๊ณ ๊ฒ์ํ๋ฉด ๋ค์ํ ์๋ฌ ์ฌ๋ก๋ค์ด ๋์ค๊ณค ํฉ๋๋ค. ์ด ๋ฌธ์ ๋ dask ์์ parquet๋ฅผ ์ฝ๋ ๋ฐฉ์์ผ๋ก ํด๊ฒฐํ ๊ฒฝํ์ด ์์ต๋๋ค. ์คํฐ๋์์ Polars๋ฅผ ์ฌ์ฉํ์
จ๋ ๊ฒฝํ์ ๊ณต์ ํด์ฃผ์
์, ์ถํ์ ๋น์ทํ ๋ฌธ์ ์ ์ฒํ ๋ Polars๋ฅผ ์ฌ์ฉํด์๋ ์ ๊ทผํด ๋ด์ผ๊ฒ ๋ค๊ณ ์๊ฐํ์ต๋๋ค.
dask์ ray์์ ml ๋ฌธ์ ๋ฅผ ์ฒ๋ฆฌํ๋ ๋ฐฉ์๋ค๋ ํฅ๋ฏธ๋ก์ ๋๋ฐ์, dask ml์์๋ ๊ธฐ์กด sklearn์ ๋ฉ์๋๋ค๊ณผ ๋์ผํ ์ฌ์ฉ ๋ฐฉ์์ผ๋ก ๊ตฌํ๋์ด ๊ธฐ์กด sklearn ์ฌ์ฉ์๋ค์ด ์ฌ์ฉ๋ฒ์ ์ตํ๊ธฐ์ ์ง์
์ฅ๋ฒฝ์ด ๋ฎ์ ๋ณด์์ต๋๋ค. ๊ทธ๋ฆฌ๊ณ Pytorch(Skorch)์ Keras(SciKeras) ์์๋ Scikit-learn๊ณผ ํธํ๋๊ฒ ๋ํํ ํ Dask ml์ parameter search๋ฅผ ์ด์ฉํ ์ ์๋ค๋ ๊ฒ๋ ํฅ๋ฏธ๋ก์ ์ต๋๋ค. ray tune๋ ํ๊ฒฝ์ด ์ ๊ตฌ์ถ๋์ด์๋ค๋ฉด ํจ๊ณผ์ ์ธ ์๋ ๊ฐ์ ์ด ๋๋ ๊ฒ์ ์๊ฒ ๋์์ต๋๋ค. ๋ค๋ง ๋ฒ์ ์ ๋ฐ๋ผ ํธํ๋์ง ์๋ ๋ฉ์๋๊ฐ ์์ด์ ์ด ๋ถ๋ถ์ ์ฃผ์๊ฐ ํ์ํด ๋ณด์์ต๋๋ค.
dask, ray์ธ์๋ duckdb, polars๋ ์ ํด๋ณผ ์ ์์์ต๋๋ค. ๊ฐ๊ฐ์ ํ๋ ์์ํฌ๋ฅผ ๊น์ด ์๊ฒ ๋ค๋ฃจ๊ธฐ์๋ ์๊ฐ์์ ์ด๋ ค์์ด ์์์ผ๋, ํ์ฉ ์ฌ๋ก๋ ํน์ง๋ค์ ์๊ฒ๋๊ณ ๊ฐ์์ ๋ถ์ผ์์ ์ ์ฉํ๋ ๋ฐฉ์์ ๋ค์ด๋ณผ ์ ์์ด์ ์ ์ตํ ์๊ฐ์ด์์ต๋๋ค.
๊ทธ๋ฆฌ๊ณ 12์์๋ ๋ฉํฐ์บ ํผ์ค์์ ๋์ปค์ ์ฟ ๋ฒ๋คํฐ์ค ์คํ๋ผ์ธ ๊ต์ก๋ ๋ฃ๊ณ , ์ด์ฌ๋ ํ๊ณ , ๊ฐ์ธ์ ์ผ๋ก ๋ง์ด ํ์ด ๋ค์๋ ํ ๋ฌ์ด์์ต๋๋ค. ๊ทธ ์์ค์๋ ๊ฑธ์ค์ธํ
๊ณผ ์น๊ตฌ๋ค ๋ฐ์
๋ ๋ค๋
์ค๋ฉฐ ๋ค์ํ ๋ถ๋ค๊ณผ ์ด์ผ๊ธฐ๋ฅผ ๋ค์ด๋ณผ ์ ์์์ต๋๋ค. 23๋
๋์ ํ๊ณ ์ถ์๋ ๊ฒ ์ค ํ๋๊ฐ ๋คํธ์ํน ํ๋๋ค์ ์ฐธ์ฌํด์ ์๊ฒฌ์ ๋ํ๋ ๊ฒ์ด์์ต๋๋ค. ์ ์ ๊ณ ๋ฏผ์ ๋ํด์๋ ๋๋์ด๋ณด๊ณ ๋ค์ํ ๊ฒฝํ์ ๋ค์ด๋ณด๋ฉฐ ์์ ์ ๋ํด์ ์ข ๋ ์๊ฒ ๋๋ ์๊ฐ์ด ๋์์ต๋๋ค.
24๋
์๋ ํจ๊ป ์ฑ์ฅํ ์ ์๋ ๊ณณ์์ ์ฑ์ฅํ๋ ํ ํด๊ฐ ๋๊ธฐ๋ฅผ ๊ธฐ์ํฉ๋๋ค !
'note' ์นดํ ๊ณ ๋ฆฌ์ ๋ค๋ฅธ ๊ธ
[Spark] Cluster Sizing - ์คํํฌ ํด๋ฌ์คํฐ ์ฌ์ด์ฆ ์ ํ๊ธฐ (0) | 2024.02.10 |
---|---|
[test] ์ฝ๊ฒ ์์ํ๋ ํ์ด์ฌ ํ ์คํธ ์ฝ๋ (0) | 2024.01.30 |
airflow ์ฌ์ฉ๊ธฐ (0) | 2023.12.05 |
[airflow] ubuntu ์๋ฒ์ airflow ์๋น์ค ๋ฑ๋กํ๊ธฐ (0) | 2023.11.18 |
[python] segno ํจํค์ง๋ฅผ ์ด์ฉํ์ฌ ๋๋ง์ QR์ฝ๋ ๋ง๋ค๊ธฐ (0) | 2023.11.14 |