- ์นดํ ๊ณ ๋ฆฌ:
DATABASE_REFRESH_PROGRESS , DATABASE_REFRESH_PROGRESS_BY_JOBยถ
DATABASE_REFRESH_PROGRESS ํจ์ ์งํฉ์ ์ฌ์ฉํ์ฌ ๋ค์ํ ์ฐจ์์ ๋ฐ๋ผ ๋ฐ์ดํฐ๋ฒ ์ด์ค ์๋ก ๊ณ ์นจ ์ํ๋ฅผ ์ฟผ๋ฆฌํ ์ ์์ต๋๋ค.
DATABASE_REFRESH_PROGRESS๋ ์ด๋ฆ๋ณ๋ก ๋ณด์กฐ ๋ฐ์ดํฐ๋ฒ ์ด์ค์ ํ์ฌ ์๋ก ๊ณ ์นจ ์ํ๋ฅผ ๋ํ๋ด๋ JSON ์ค๋ธ์ ํธ๋ฅผ ๋ฐํํฉ๋๋ค.
DATABASE_REFRESH_PROGRESS_BY_JOB์ ์๋ก ๊ณ ์นจ ์ฟผ๋ฆฌ๋ฅผ ํตํด ๋ณด์กฐ ๋ฐ์ดํฐ๋ฒ ์ด์ค์ ํ์ฌ ์๋ก ๊ณ ์นจ ์ํ๋ฅผ ๋ํ๋ด๋ JSON ์ค๋ธ์ ํธ๋ฅผ ๋ฐํํฉ๋๋ค.
๊ฐ ํจ์๋ ์ง์ ๋ ์ฐจ์์ ๋ฐ๋ผ ์ฟผ๋ฆฌํ๋๋ก ์ต์ ํ๋์ด ์์ต๋๋ค.
์ฐธ๊ณ
DATABASE_REFRESH_PROGRESS๋ ๋ฐ์ดํฐ๋ฒ ์ด์ค ์๋ก ๊ณ ์นจ์ด ์ต๊ทผ 14์ผ ์ด๋ด์ ๋ฐ์ํ ๊ฒฝ์ฐ, ๊ฐ์ฅ ์ต๊ทผ์ ๋ฐ์ดํฐ๋ฒ ์ด์ค ์๋ก ๊ณ ์นจ์ ๋ํ ๋ฐ์ดํฐ๋ฒ ์ด์ค ์๋ก ๊ณ ์นจ ํ๋๋ง ๋ฐํํฉ๋๋ค.
DATABASE_REFRESH_PROGRESS_BY_JOB์ ์ง๋ 14์ผ ์ด๋ด์ ๋ฐ์ดํฐ๋ฒ ์ด์ค ์๋ก ๊ณ ์นจ ํ๋์ ๋ฐํํฉ๋๋ค.
- ์ฐธ๊ณ ํญ๋ชฉ:
๊ตฌ๋ฌธยถ
DATABASE_REFRESH_PROGRESS( '<secondary_db_name>' )
DATABASE_REFRESH_PROGRESS_BY_JOB( '<query_id>' )
์ธ์ยถ
secondary_db_name
๋ณด์กฐ ๋ฐ์ดํฐ๋ฒ ์ด์ค์ ์ด๋ฆ์ ๋๋ค. ๋ณด์กฐ ๋ฐ์ดํฐ๋ฒ ์ด์ค๊ฐ ํ์ฌ ์ธ์ ์ ํ์ฑ ๋ฐ์ดํฐ๋ฒ ์ด์ค์ธ ๊ฒฝ์ฐ, ์ด ์ธ์๋ ์ ํ ์ฌํญ์ ๋๋ค.
์ ์ฒด ์ด๋ฆ์ ์์๋ฐ์ดํ๋ก ๋ฌถ์ด์ผ ํฉ๋๋ค.
query_id
๋ฐ์ดํฐ๋ฒ ์ด์ค ์๋ก ๊ณ ์นจ ์ฟผ๋ฆฌ์ ID์ ๋๋ค. ์ฟผ๋ฆฌ ID๋ ์น ์ธํฐํ์ด์ค์ History
ํ์ด์ง์์ ์ป์ ์ ์์ต๋๋ค.
์ฌ์ฉ๋ฒ ๋ ธํธยถ
๊ณ์ ๊ด๋ฆฌ์(ACCOUNTADMIN ์ญํ ์ ๊ฐ์ง ์ฌ์ฉ์)์ ๋ํ ๊ฒฐ๊ณผ๋ง ๋ฐํํฉ๋๋ค.
Information Schema ํ ์ด๋ธ ํจ์๋ฅผ ํธ์ถํ ๋ ์ธ์ ์๋ ์ฌ์ฉ ์ค์ธ INFORMATION_SCHEMA ์คํค๋ง๊ฐ ์๊ฑฐ๋ ๋๋ ํจ์ ์ด๋ฆ์ด ์ ๊ทํ๋์ด์ผ ํฉ๋๋ค. ์์ธํ ๋ด์ฉ์ Snowflake Information Schema ์น์ ์ ์ฐธ์กฐํ์ญ์์ค.
๋ค์์ ์ฒ๋ฆฌ๋ ์์์ ๋จ๊ณ ๋ชฉ๋ก์ ๋๋ค.
SECONDARY_UPLOADING_INVENTORY
PRIMARY_UPLOADING_METADATA
PRIMARY_UPLOADING_DATA
SECONDARY_DOWNLOADING_METADATA
SECONDARY_DOWNLOADING_DATA
COMPLETED / FAILED / CANCELED
์ถ๋ ฅยถ
์ด ํจ์๋ ๋ค์ ์ด์ ๋ฐํํฉ๋๋ค.
์ด ์ด๋ฆ |
๋ฐ์ดํฐ ํ์ |
์ค๋ช |
---|---|---|
PHASE_NAME |
TEXT |
์ง๊ธ๊น์ง ์๋ฃ๋(๋๋ ์งํ ์ค์ธ) ๋ณต์ ๋จ๊ณ์ ์ด๋ฆ์ ๋๋ค. ๋จ๊ณ ๋ชฉ๋ก์ ์ฌ์ฉ๋ฒ ๋ ธํธ๋ฅผ ์ฐธ์กฐํ์ญ์์ค. |
RESULT |
TEXT |
๋ณต์ ๋จ๊ณ์ ์ํ์
๋๋ค. ์ ํจํ ์ํ๋ |
START_TIME |
NUMBER |
๋ณต์ ๋จ๊ณ๊ฐ ์์๋ ์๊ฐ์ ๋๋ค. ํ์์ Epoch ์๊ฐ์ ๋๋ค. |
END_TIME |
NUMBER |
๋จ๊ณ๊ฐ ์๋ฃ๋ ์๊ฐ์ ๋๋ค(ํด๋นํ๋ ๊ฒฝ์ฐ). ํ์์ Epoch ์๊ฐ์ ๋๋ค. |
DETAILS |
VARIANT |
DATABASE_REFRESH_PROGRESS ํจ์์์๋ง ๋ฐํ๋ฉ๋๋ค. ๋ค์ ๋จ๊ณ์ ๋ํ ์์ธํ ์ ๋ณด๋ฅผ ์ ๊ณตํ๋ JSON ์ค๋ธ์ ํธ: . - ๊ธฐ๋ณธ ์ ๋ก๋ ๋ฐ์ดํฐ: ๊ธฐ๋ณธ ๋ฐ์ดํฐ๋ฒ ์ด์ค์ ํ์ฌ ์ค๋ ์ท ํ์์คํฌํ. . - ๊ธฐ๋ณธ ์ ๋ก๋ ๋ฐ์ดํฐ ๋ฐ ๋ณด์กฐ ๋ค์ด๋ก๋ ๋ฐ์ดํฐ: ๋ฐ์ดํฐ๋ฒ ์ด์ค ์๋ก ๊ณ ์นจ์ ์ด ๋ฐ์ดํธ ์, ๊ทธ๋ฆฌ๊ณ ๋จ๊ณ์์ ์ง๊ธ๊น์ง ๋ณต์ฌ๋ ๋ฐ์ดํธ ์. . - ๋ณด์กฐ ๋ค์ด๋ก๋ ๋ฉํ๋ฐ์ดํฐ: ๊ธฐ๋ณธ ๋ฐ์ดํฐ๋ฒ ์ด์ค์ ์ต์ ์ค๋ ์ท์ ์๋ ํ ์ด๋ธ, ํ ์ด๋ธ ์ด, ๋ชจ๋ ๋ฐ์ดํฐ๋ฒ ์ด์ค ์ค๋ธ์ ํธ(ํ ์ด๋ธ ๋ฐ ํ ์ด๋ธ ์ด ํฌํจ)์ ์. |
์ยถ
mydb1
๋ฐ์ดํฐ๋ฒ ์ด์ค์ ๋ํ ๋ฐ์ดํฐ๋ฒ ์ด์ค ์๋ก ๊ณ ์นจ์ ํ์ฌ ์งํ๋ฅ ์ ๊ฒ์ํฉ๋๋ค.
select * from table(information_schema.database_refresh_progress(mydb1));
์ฟผ๋ฆฌ ID๋ก ๋ฐ์ดํฐ๋ฒ ์ด์ค ์๋ก ๊ณ ์นจ์ ํ์ฌ ์งํ๋ฅ ์ ๊ฒ์ํฉ๋๋ค.
select * from table(information_schema.database_refresh_progress_by_job('012a3b45-1234-a12b-0000-1aa200012345'));