์นดํ…Œ๊ณ ๋ฆฌ:

Information Schema , ํ…Œ์ด๋ธ” ํ•จ์ˆ˜

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_HISTORY

๊ตฌ๋ฌธยถ

DATABASE_REFRESH_PROGRESS( '<secondary_db_name>' )

DATABASE_REFRESH_PROGRESS_BY_JOB( '<query_id>' )
Copy

์ธ์žยถ

secondary_db_name

๋ณด์กฐ ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค์˜ ์ด๋ฆ„์ž…๋‹ˆ๋‹ค. ๋ณด์กฐ ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค๊ฐ€ ํ˜„์žฌ ์„ธ์…˜์˜ ํ™œ์„ฑ ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค์ธ ๊ฒฝ์šฐ, ์ด ์ธ์ž๋Š” ์„ ํƒ ์‚ฌํ•ญ์ž…๋‹ˆ๋‹ค.

์ „์ฒด ์ด๋ฆ„์€ ์ž‘์€๋”ฐ์˜ดํ‘œ๋กœ ๋ฌถ์–ด์•ผ ํ•ฉ๋‹ˆ๋‹ค.

query_id

๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค ์ƒˆ๋กœ ๊ณ ์นจ ์ฟผ๋ฆฌ์˜ ID์ž…๋‹ˆ๋‹ค. ์ฟผ๋ฆฌ ID๋Š” ์›น ์ธํ„ฐํŽ˜์ด์Šค์˜ History ๊ธฐ๋ก ํƒญ ํŽ˜์ด์ง€์—์„œ ์–ป์„ ์ˆ˜ ์žˆ์Šต๋‹ˆ๋‹ค.

์‚ฌ์šฉ๋ฒ• ๋…ธํŠธยถ

  • ๊ณ„์ • ๊ด€๋ฆฌ์ž(ACCOUNTADMIN ์—ญํ• ์„ ๊ฐ€์ง„ ์‚ฌ์šฉ์ž)์— ๋Œ€ํ•œ ๊ฒฐ๊ณผ๋งŒ ๋ฐ˜ํ™˜ํ•ฉ๋‹ˆ๋‹ค.

  • Information Schema ํ…Œ์ด๋ธ” ํ•จ์ˆ˜๋ฅผ ํ˜ธ์ถœํ•  ๋•Œ ์„ธ์…˜์—๋Š” ์‚ฌ์šฉ ์ค‘์ธ INFORMATION_SCHEMA ์Šคํ‚ค๋งˆ๊ฐ€ ์žˆ๊ฑฐ๋‚˜ ๋˜๋Š” ํ•จ์ˆ˜ ์ด๋ฆ„์ด ์ •๊ทœํ™”๋˜์–ด์•ผ ํ•ฉ๋‹ˆ๋‹ค. ์ž์„ธํ•œ ๋‚ด์šฉ์€ Snowflake Information Schema ์„น์…˜์„ ์ฐธ์กฐํ•˜์‹ญ์‹œ์˜ค.

  • ๋‹ค์Œ์€ ์ฒ˜๋ฆฌ๋œ ์ˆœ์„œ์˜ ๋‹จ๊ณ„ ๋ชฉ๋ก์ž…๋‹ˆ๋‹ค.

    1. SECONDARY_UPLOADING_INVENTORY

    2. PRIMARY_UPLOADING_METADATA

    3. PRIMARY_UPLOADING_DATA

    4. SECONDARY_DOWNLOADING_METADATA

    5. SECONDARY_DOWNLOADING_DATA

    6. COMPLETED / FAILED / CANCELED

์ถœ๋ ฅยถ

์ด ํ•จ์ˆ˜๋Š” ๋‹ค์Œ ์—ด์„ ๋ฐ˜ํ™˜ํ•ฉ๋‹ˆ๋‹ค.

์—ด ์ด๋ฆ„

๋ฐ์ดํ„ฐ ํƒ€์ž…

์„ค๋ช…

PHASE_NAME

TEXT

์ง€๊ธˆ๊นŒ์ง€ ์™„๋ฃŒ๋œ(๋˜๋Š” ์ง„ํ–‰ ์ค‘์ธ) ๋ณต์ œ ๋‹จ๊ณ„์˜ ์ด๋ฆ„์ž…๋‹ˆ๋‹ค. ๋‹จ๊ณ„ ๋ชฉ๋ก์€ ์‚ฌ์šฉ๋ฒ• ๋…ธํŠธ๋ฅผ ์ฐธ์กฐํ•˜์‹ญ์‹œ์˜ค.

RESULT

TEXT

๋ณต์ œ ๋‹จ๊ณ„์˜ ์ƒํƒœ์ž…๋‹ˆ๋‹ค. ์œ ํšจํ•œ ์ƒํƒœ๋Š” EXECUTING, SUCCEEDED, CANCELLED, FAILED ์ž…๋‹ˆ๋‹ค.

START_TIME

NUMBER

๋ณต์ œ ๋‹จ๊ณ„๊ฐ€ ์‹œ์ž‘๋œ ์‹œ๊ฐ„์ž…๋‹ˆ๋‹ค. ํ˜•์‹์€ Epoch ์‹œ๊ฐ„์ž…๋‹ˆ๋‹ค.

END_TIME

NUMBER

๋‹จ๊ณ„๊ฐ€ ์™„๋ฃŒ๋œ ์‹œ๊ฐ„์ž…๋‹ˆ๋‹ค(ํ•ด๋‹นํ•˜๋Š” ๊ฒฝ์šฐ). ํ˜•์‹์€ Epoch ์‹œ๊ฐ„์ž…๋‹ˆ๋‹ค.

DETAILS

VARIANT

DATABASE_REFRESH_PROGRESS ํ•จ์ˆ˜์—์„œ๋งŒ ๋ฐ˜ํ™˜๋ฉ๋‹ˆ๋‹ค. ๋‹ค์Œ ๋‹จ๊ณ„์— ๋Œ€ํ•œ ์ž์„ธํ•œ ์ •๋ณด๋ฅผ ์ œ๊ณตํ•˜๋Š” JSON ์˜ค๋ธŒ์ ํŠธ: . - ๊ธฐ๋ณธ ์—…๋กœ๋“œ ๋ฐ์ดํ„ฐ: ๊ธฐ๋ณธ ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค์˜ ํ˜„์žฌ ์Šค๋ƒ…์ƒท ํƒ€์ž„์Šคํƒฌํ”„. . - ๊ธฐ๋ณธ ์—…๋กœ๋“œ ๋ฐ์ดํ„ฐ ๋ฐ ๋ณด์กฐ ๋‹ค์šด๋กœ๋“œ ๋ฐ์ดํ„ฐ: ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค ์ƒˆ๋กœ ๊ณ ์นจ์˜ ์ด ๋ฐ”์ดํŠธ ์ˆ˜, ๊ทธ๋ฆฌ๊ณ  ๋‹จ๊ณ„์—์„œ ์ง€๊ธˆ๊นŒ์ง€ ๋ณต์‚ฌ๋œ ๋ฐ”์ดํŠธ ์ˆ˜. . - ๋ณด์กฐ ๋‹ค์šด๋กœ๋“œ ๋ฉ”ํƒ€๋ฐ์ดํ„ฐ: ๊ธฐ๋ณธ ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค์˜ ์ตœ์‹  ์Šค๋ƒ…์ƒท์— ์žˆ๋Š” ํ…Œ์ด๋ธ”, ํ…Œ์ด๋ธ” ์—ด, ๋ชจ๋“  ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค ์˜ค๋ธŒ์ ํŠธ(ํ…Œ์ด๋ธ” ๋ฐ ํ…Œ์ด๋ธ” ์—ด ํฌํ•จ)์˜ ์ˆ˜.

์˜ˆยถ

mydb1 ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค์— ๋Œ€ํ•œ ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค ์ƒˆ๋กœ ๊ณ ์นจ์˜ ํ˜„์žฌ ์ง„ํ–‰๋ฅ ์„ ๊ฒ€์ƒ‰ํ•ฉ๋‹ˆ๋‹ค.

select *
from table(information_schema.database_refresh_progress(mydb1));
Copy

์ฟผ๋ฆฌ ID๋กœ ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค ์ƒˆ๋กœ ๊ณ ์นจ์˜ ํ˜„์žฌ ์ง„ํ–‰๋ฅ ์„ ๊ฒ€์ƒ‰ํ•ฉ๋‹ˆ๋‹ค.

select *
from table(information_schema.database_refresh_progress_by_job('012a3b45-1234-a12b-0000-1aa200012345'));
Copy