Metatron-discovery: Improve processing log during datasource ingestion

Created on 11 Nov 2018  ยท  12Comments  ยท  Source: metatron-app/metatron-discovery

Is your feature request related to a problem? Please describe.
ํ˜„์žฌ๋Š” ๋ฐ์ดํ„ฐ ์ ์žฌ ์‹คํŒจ์‹œ์—๋งŒ Detail ๋งํฌ๋ฅผ ํ†ตํ•ด ๋กœ๊ทธ ํ˜•ํƒœ๋กœ ์ ์žฌ ์ƒํƒœ์— ๋Œ€ํ•ด ํ‘œํ˜„ํ•˜๊ณ  ์žˆ์ง€๋งŒ, ์ ์žฌ ์ฒ˜๋ฆฌ์ค‘ ํ”„๋กœ์„ธ์Šค์— ๋Œ€ํ•ด log ๋กœ ํ‘œํ˜„ํ•˜๊ณ  ์žˆ์ง€ ์•Š์Šต๋‹ˆ๋‹ค.

Describe the solution you'd like
์‚ฌ์šฉ์ž๋Š” ํ˜„์žฌ ์ ์žฌ ์ƒํƒœ์— ๋Œ€ํ•ด ๊ถ๊ธˆํ•ด ํ• ์ˆ˜ ์žˆ๊ธฐ ๋•Œ๋ฌธ์—, ์‹ค์‹œ๊ฐ„์œผ๋กœ ์ด์— ๋Œ€ํ•œ ์ฒ˜๋ฆฌ๋ฅผ ๊ณ ๋ คํ•ฉ๋‹ˆ๋‹ค.
(ex. Workbench ๋กœ๊ทธ ์ƒํƒœ ํ‘œํ˜„ ๋ฐฉ์‹)

Describe alternatives you've considered
์ „์ฒด ๋‹จ๊ณ„ ๊ณ ๋ ค๊ฐ€ ์–ด๋ ต๋‹ค๋ฉด ์—”์ง„๋‚ด Task Log ๋ฅผ ํ‘œํ˜„ํ•˜๋Š” ๋ฐฉ์‹, ๋ฆฌํ”„๋ ˆ์‰ฌ ์ฒ˜๋ฆฌ ๋ฐฉ์‹๋„ ํ•จ๊ป˜ ๊ฒ€ํ† ํ•ด๋ณด์•˜์œผ๋ฉด ํ•ฉ๋‹ˆ๋‹ค.

Additional context
์—”์ง„๋‚ด ๋ฐ์ดํ„ฐ ์ ์žฌ ๋กœ๊ทธ์— ๋Œ€ํ•œ ์‹ค์‹œ๊ฐ„ ๋ฐ์ดํ„ฐ ์ฒ˜๋ฆฌ๋ฅผ ์ถ”๊ฐ€์ ์œผ๋กœ ๊ณ ๋ฏผํ•ฉ๋‹ˆ๋‹ค. (offset ๊ด€๋ จ)

enhancement @datasource awaiting feedback

All 12 comments

@AnnieHwang @metatron-app/design ์œ„์˜๋‚ด์šฉ์— ๋Œ€ํ•ด ๋…ผ์˜๊ฐ€ ํ•„์š”ํ•œ๋ฐ์š”. ํ™•์ธ ๋ถ€ํƒ๋“œ๋ฆฝ๋‹ˆ๋‹ค.

@kyungtaak @AnnieHwang
๋ฐ์ดํ„ฐ ์ ์žฌ ์ƒํƒœ ์•„๋ž˜ log ์˜์—ญ์„ ๋ฐฐ์น˜ํ•˜๋ฉด ์–ด๋–จ๊นŒํ•ฉ๋‹ˆ๋‹ค.
์ด๋ ‡๊ฒŒ ๋  ๊ฒฝ์šฐ ํ˜„์žฌ๋Š” 'Failed' ์ƒํƒœ์ผ๋•Œ๋งŒ ํŒ์—…์œผ๋กœ log๋ฅผ ๋„์šฐ๋Š”๋ฐ, ๋ชจ๋‘ ํ•˜๋‹จ ์ธ๋ผ์ธ ๋ฐฐ์น˜๋กœ ํ†ต์ผ๋ฉ๋‹ˆ๋‹ค.

ํ•ด๋‹น ์˜์—ญ์€ ์•„์ฝ”๋””์–ธ ํƒญ์œผ๋กœ ๋‹ซํžŒ ์ƒํƒœ๊ฐ€ ๊ธฐ๋ณธ์ธ๋ฐ, 'Preparing' ์ƒํƒœ์—๋Š” ์—ด๋ฆฐ์ƒํƒœ์ž…๋‹ˆ๋‹ค.
736_processinglog

@deidera08 ๊ธฐํš๋‚ด์šฉ์€ ์ž˜๋ณด์•˜์Šต๋‹ˆ๋‹ค. ํ•œ๊ฐ€์ง€ ์ผ€์ด์Šค์— ๋Œ€ํ•ด ์ถ”๊ฐ€ ๊ฒ€ํ†  ์š”์ฒญ ๋“œ๋ฆฝ๋‹ˆ๋‹ค.
์—”์ง„(Druid) ์—์„œ ์ „๋‹ฌ๋ฐ›๋Š” ๋กœ๊ทธ๋Š” ๊ธด~~~~ ๊ฒฝ์šฐ๊ฐ€ ์žˆ์Šต๋‹ˆ๋‹ค. ์ด๊ฒฝ์šฐ๋Š” ์–ด๋–ป๊ฒŒ ์ฒ˜๋ฆฌํ•˜๋ฉด ์ข‹์„๊นŒ์š”? ์ธ๋ผ์ธ์ผ๊ฒฝ์šฐ ๋ณด๋Š” ํฌ๊ธฐ๊ฐ€ ํ•œ์ •์ ์ด์–ด์„œ ๋ถˆํŽธํ• ๊ฒƒ ๊ฐ™์€๋ฐ์š”. ๊ฒ€ํ†  ๋ถ€ํƒ๋“œ๋ฆฝ๋‹ˆ๋‹ค.

@kyungtaak @AnnieHwang
Log ์˜์—ญ ๋‚ด [ํŒ์—…๋ณด๊ธฐ] ๊ธฐ๋Šฅ์„ ์ถ”๊ฐ€ํ•˜๋ฉด ์–ด๋–จ๊นŒ ํ•ฉ๋‹ˆ๋‹ค.

์ œ๊ฐ€ ์ƒ๊ฐํ–ˆ์„๋•Œ log view๋Š” ํ˜„์žฌ ์ง„ํ–‰(processing) ์ƒํ™ฉ์ด๋‚˜ ์‹คํŒจ์ง€์  ์ถ”์ ์ด ์ค‘์š”ํ•  ๋“ฏ ํ•˜์ง€๋งŒ
๋ถ€๋ชจ ํ™”๋ฉด์ด information์ž„์„ ๊ฐ์•ˆํ• ๋•Œ, ํ•ด๋‹น log๋ฅผ ํ…์ŠคํŠธ ํŒŒ์ผ๋กœ ๋‹ค์šด๋กœ๋“œ๋ฐ›๊ฑฐ๋‚˜ ์œˆ๋„์šฐ ์ƒˆ์ฐฝ(์ƒˆํƒญ)์„ ๋„์šธ ์ •๋„๋Š” ์•„๋‹Œ๋“ฏ ํ•ฉ๋‹ˆ๋‹ค.
์‚ดํŽด๋ณด์‹œ๊ณ , ๋ถ€์กฑํ•˜๋ฉด ์ข€ ๋” ๋ณด์™„ํ•˜๊ฒ ์Šต๋‹ˆ๋‹ค.

Datasource information
736_ingestionlog1

Datasource information > ingestion popup
736_ingestionlog2

@deidera08 ์ข‹์€ ์˜๊ฒฌ ์ฃผ์…”์„œ ๊ฐ์‚ฌํ•ฉ๋‹ˆ๋‹ค. ํ˜น์‹œ "๋งจ์•„๋ž˜๋กœ" ๋ฒ„ํŠผ์ด ๋งŽ์ด ํ•„์š”ํ• ๊นŒ์š”? ๊ทธ๋ฆฌ๊ณ  ๊ธฐ๋ณธ์ด ๋งจ์•„๋ž˜๋กœ ์Šคํฌ๋กค๋กœ ํ˜„์žฌ๋Š” ๋˜์–ด ์žˆ์Šต๋‹ˆ๋‹ค.

@kyungtaak
์Šคํฌ๋กค์ด ์ž๋™์œผ๋กœ ๋งจ ์•„๋žซ์ค„์„ ํŠธ๋ž˜ํ‚นํ•œ๋‹ค๋ฉด [๋งจ์•„๋ž˜๋กœ]๋ฒ„ํŠผ์€ ํ•„์š”์—†์Šต๋‹ˆ๋‹ค.
๊ธฐํš์„œ์—์„œ ์ œ๊ฑฐํ•˜๋„๋ก ํ•˜๊ฒ ์Šต๋‹ˆ๋‹ค.

image
image

@AnnieHwang ๋””์ž์ธ๊ณต์œ ๋“œ๋ฆฝ๋‹ˆ๋‹ค

736_ingestionlogarea
์ด์Šˆ ๋‚ด์šฉ ์ ์šฉํ•œ ์™€์ด์–ดํ”„๋ ˆ์ž„ ์žฌ๊ณต์œ  ๋“œ๋ฆฝ๋‹ˆ๋‹ค.

๊ธฐ์กด DataSource Progress Topic(์›น์†Œ์ผ“)์— ์ถ”๊ฐ€์ ์ธ message๊ฐ€ ๋ณด๋‚ด์งˆ ์˜ˆ์ •์ž…๋‹ˆ๋‹ค.

์•„๋ž˜๋Š” ๋ฉ”์‹œ์ง€ ์ƒ˜ํ”Œ์ž…๋‹ˆ๋‹ค.

{
  "command" : "LOG",
  "log" : {
    "offset" : 1024,
    "logs" : "log message"
  }

Task ๋กœ๊ทธ๋Š” "ENGINE_RUNNING_TASK" ๋‹จ๊ณ„ ์ดํ›„๋ถ€ํ„ฐ ๋ณด๋‚ด์ง€๋ฉฐ
task ์‹คํ–‰ ์ดˆ๊ธฐ์—๋Š” offset ๊ฐ’์ด ์—†๊ณ  task๊ฐ€ ์‹œ์ž‘๋˜๊ธฐ ์ „์ด๋ผ๋Š” ์—๋Ÿฌ๋ฉ”์‹œ์ง€๊ฐ€ ๋‚ด๋ ค๊ฐ‘๋‹ˆ๋‹ค.

"Fail to process response : [No log was found for this task. The task may not exist, or it may not have begun running yet.]"

์‹ค์ œ task๊ฐ€ ์‹œ์ž‘๋˜๋ฉด ๋กœ๊ทธ ๋ฉ”์‹œ์ง€๊ฐ€ ๋ณด๋‚ด์ง‘๋‹ˆ๋‹ค.
๋กœ๊ทธ ๋ฉ”์‹œ์ง€๋Š” ๊ณ„์† append ํ•ด์ฃผ์‹œ๋ฉด ๋ฉ๋‹ˆ๋‹ค.

DataSource ์ƒ์„ธ ๋ณด๊ธฐ ํ™”๋ฉด ์ง„์ž… ์‹œ history์˜ progress๊ฐ€ "ENGINE_RUNNING_TASK" ๋ผ๋ฉด ์‹ค์‹œ๊ฐ„ task ๋กœ๊ทธ๋ฅผ append ํ•˜๊ธฐ ์ „์— ๊ธฐ์กด log๋ฅผ ์š”์ฒญํ•œ ๋’ค ์‹ค์‹œ๊ฐ„ task ๋กœ๊ทธ๋ฅผ append ํ•ด์•ผ ์ „์ฒด ๋กœ๊ทธ๊ฐ€ ๋ณด์—ฌ์งˆ์ˆ˜ ์žˆ์œผ๋‹ˆ ์ฐธ๊ณ ํ•˜์‹œ๊ธฐ ๋ฐ”๋ž๋‹ˆ๋‹ค.

@AnnieHwang ํ•ด๋‹น๊ฑด์€ ๊ธˆ์ฃผ ํšŒ์˜๋•Œ ๋…ผ์˜ํ•œ ๋ฐ”์™€ ๊ฐ™์ด ๊ธฐํš๋‚ด์šฉ์ด ์ •๋ฆฌ๊ฐ€ ๋œํ›„ ์ง„ํ–‰ํ•˜๋„๋ก ํ• ๊ฒŒ์š”. f/u ๋ถ€ํƒ๋“œ๋ฆฝ๋‹ˆ๋‹ค. (์šฐ์„ ์ˆœ์œ„๋Š” ๋‚ฎ์•„์š”.;)

@kyungtaak @AnnieHwang @ufoscw

๋‹ค์Œ๊ณผ ๊ฐ™์ด ์ •๋ฆฌํ•˜์˜€์Šต๋‹ˆ๋‹ค.

  1. ์›Œํฌ๋ฒค์น˜์™€ ์œ ์‚ฌํ•œ ๋””์ž์ธ์„ ์ œ๊ณตํ•ฉ๋‹ˆ๋‹ค.
  2. '๋”๋ณด๊ธฐ'๋กœ ์•„์ฝ”๋””์–ธํƒญ์œผ๋กœ ๋™์ž‘ํ•˜๋˜ ๋ถ€๋ถ„์„ ์‚ญ์ œํ•˜๊ณ  ์ƒ์‹œ๋…ธ์ถœํ•ฉ๋‹ˆ๋‹ค.
  3. Ingestion์˜ ์ƒํƒœ(running, waiting, pending, complete)๋ฅผ ๋…ธ์ถœํ•˜๊ณ  ์—๋Ÿฌ/๊ฒฝ๊ณ ์˜ ์ˆ˜๋ฅผ ์นด์šดํŒ…ํ•ฉ๋‹ˆ๋‹ค.
    (์—๋Ÿฌ/๊ฒฝ๊ณ ์˜ ์ˆ˜๋ฅผ ์นด์šดํŒ… ์ง€์› ์—ฌ๋ถ€ ํ™•์ธ ํ•„์š”)
  4. ์‹ค์‹œ๊ฐ„ ๋กœ๊ทธ๋ฅผ ์ œ๊ณตํ•˜๋ฉฐ, ๋กœ๊ทธ๊ฐ€ ๊ณผ๋„ํ•˜๊ฒŒ ์Œ“์ผ๊ฒฝ์šฐ ์ดˆ๊ธฐ ๋กœ๊ทธ๋ฅผ ์ƒ๋žตํ•ฉ๋‹ˆ๋‹ค.
    (์ด๋•Œ scroll up์‹œ ๊ฐ€์ด๋“œ๋ฌธ๊ตฌ ํ‘œํ˜„ ๊ฐ€๋Šฅํ•œ์ง€ ํ™•์ธ ํ•„์š”)
  5. ์ดˆ๊ธฐ ๋กœ๊ทธ ์ƒ๋žต๊ณผ ๊ด€๊ณ„์—†์ด ๋กœ๊ทธ๋ฅผ ์ƒˆํƒญ์ด๋‚˜ ํŒŒ์ผ๋กœ ๋‹ค์šด๋กœ๋“œ ํ•  ๊ฒฝ์šฐ ์ „์ฒด ๋กœ๊ทธ๋ฅผ ๋ณผ ์ˆ˜ ์žˆ์Šต๋‹ˆ๋‹ค.
    2019-02-21 2 37 10
    default

์‚ดํŽด๋ณด์‹œ๊ณ  ๋ณด์™„ํ•ด์•ผ ํ•  ์‚ฌํ•ญ์ด๋‚˜ (๊ฒ€ํ† ์‚ฌํ•ญ์— ๋Œ€ํ•œ)์˜๊ฒฌ์„ ๋ชจ์ชผ๋ก ๋ถ€ํƒ๋“œ๋ฆฌ๊ฒ ์Šต๋‹ˆ๋‹ค.

@AnnieHwang ๋””์ž์ธํ™”๋ฉด ๊ณต์œ ๋“œ๋ฆฝ๋‹ˆ๋‹ค-

  • ์‹œ๊ฐ„ ํ…์ŠคํŠธ์— ์ปฌ๋Ÿฌ ์ ์šฉ
  • ํ™”๋ฉด ํฌ๊ธฐ์—๋”ฐ๋ผ ๊ฐ€๋กœ์˜์—ญ ๊ฐ€๋ณ€
    image
Was this page helpful?
0 / 5 - 0 ratings