Postgres Record Manager

PostgreSQL ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค์— AI ํŒŒ์ดํ”„๋ผ์ธ ๊ฒฐ๊ณผ๋ฅผ ์ €์žฅํ•˜๊ณ  ๊ด€๋ฆฌํ•  ์ˆ˜ ์žˆ๋„๋ก ๊ตฌ์„ฑ๋œ ๋…ธ๋“œ์ž…๋‹ˆ๋‹ค. ํŠน์ • ํ…Œ์ด๋ธ”์— ๋Œ€ํ•œ ์ž๋™ upsert ๊ธฐ๋Šฅ๊ณผ namespace ๊ธฐ๋ฐ˜ ๋ถ„๋ฅ˜, cleanup ์„ค์ •์„ ํ†ตํ•œ ๋ฐ์ดํ„ฐ ์ •๋ฆฌ๊ฐ€ ๊ฐ€๋Šฅํ•˜์—ฌ ๋ฐ˜๋ณต ์‹คํ–‰๋˜๋Š” ์ž๋™ํ™” ์›Œํฌํ”Œ๋กœ์šฐ์™€ ํ†ตํ•ฉ ํ™œ์šฉ์— ์ ํ•ฉํ•ฉ๋‹ˆ๋‹ค.


์ฃผ์š” ๊ธฐ๋Šฅ

  • PostgreSQL๊ณผ ์—ฐ๋™ํ•˜์—ฌ AI ์ฒ˜๋ฆฌ ๊ฒฐ๊ณผ๋ฅผ ๊ตฌ์กฐํ™”๋œ ํ˜•ํƒœ๋กœ ์ €์žฅ ๋ฐ ์—…๋ฐ์ดํŠธ

  • Namespace, SourceId ๊ธฐ๋ฐ˜์œผ๋กœ ์›Œํฌํ”Œ๋กœ์šฐ๋ณ„ ๋ฐ์ดํ„ฐ ๋ถ„๋ฆฌ ๋ฐ ์ค‘๋ณต ๋ฐฉ์ง€

  • Cleanup ์˜ต์…˜์„ ํ†ตํ•œ ๋ฐ์ดํ„ฐ ์ •๋ฆฌ ์ „๋žต ์ ์šฉ ๊ฐ€๋Šฅ

  • SSL ์˜ต์…˜ ์ œ๊ณต์œผ๋กœ ๋ณด์•ˆ ์—ฐ๊ฒฐ ์ง€์›

  • ๊ธฐ๋ณธ ํ…Œ์ด๋ธ” ์ž๋™ ์ƒ์„ฑ(upsertion_records) ๋˜๋Š” ์‚ฌ์šฉ์ž ์ง€์ • ๊ฐ€๋Šฅ

WindyFlo Postgres Record Manager
WindyFlo Postgres Record Manager Parameters

์ž…๋ ฅ๊ฐ’ (Inputs)

ํ•ญ๋ชฉ
์„ค๋ช…
ํ•„์ˆ˜ ์—ฌ๋ถ€

Connect Credential

PostgreSQL ์ ‘์† ์ •๋ณด๋ฅผ ๋‹ด์€ Credential์— ๋“ฑ๋ก๋œ ํ•ญ๋ชฉ ์„ ํƒ

ํ•„์ˆ˜

Host

PostgreSQL ์„œ๋ฒ„ ์ฃผ์†Œ ๋˜๋Š” ๋„๋ฉ”์ธ

ํ•„์ˆ˜

Database

์—ฐ๊ฒฐํ•  ๋Œ€์ƒ ๋ฐ์ดํ„ฐ๋ฒ ์ด์Šค ์ด๋ฆ„

ํ•„์ˆ˜

Port

์ ‘์† ํฌํŠธ ๋ฒˆํ˜ธ (๊ธฐ๋ณธ๊ฐ’: 5432)

์„ ํƒ

Additional Parameters

ํ•ญ๋ชฉ
์„ค๋ช…
ํ•„์ˆ˜ ์—ฌ๋ถ€

SSL

๋ณด์•ˆ ์—ฐ๊ฒฐ์„ ์œ„ํ•œ SSL ์‚ฌ์šฉ ์—ฌ๋ถ€ (๊ธฐ๋ณธ๊ฐ’: ๋น„ํ™œ์„ฑํ™”)

์„ ํƒ

Table Name

๋ฐ์ดํ„ฐ๋ฅผ ์ €์žฅํ•  ํ…Œ์ด๋ธ” ์ด๋ฆ„ (๊ธฐ๋ณธ๊ฐ’: upsertion_records)

์„ ํƒ

Namespace

๋ ˆ์ฝ”๋“œ๋ฅผ ๋…ผ๋ฆฌ์ ์œผ๋กœ ๊ตฌ๋ถ„ํ•˜๋Š” ํ‚ค. ํ”„๋กœ์ ํŠธ ๋‹จ์œ„ ๊ตฌ๋ถ„ ์‹œ ์œ ์šฉ

์„ ํƒ

Cleanup

๊ธฐ์กด ๋ฐ์ดํ„ฐ ์ •๋ฆฌ ๋ฐฉ์‹. None, full, partial ๋“ฑ ์„ค์ • ๊ฐ€๋Šฅ

ํ•„์ˆ˜

SourceId Key

์ค‘๋ณต ํŒ๋‹จ ๊ธฐ์ค€์ด ๋˜๋Š” ํ•„๋“œ๋ช…. ๊ธฐ๋ณธ๊ฐ’: source

์„ ํƒ


์ถœ๋ ฅ๊ฐ’ (Outputs)

์ถœ๋ ฅ ํ•ญ๋ชฉ
์„ค๋ช…

PostgresRecordManager

๊ตฌ์„ฑ๋œ PostgreSQL ๋ ˆ์ฝ”๋“œ ๊ด€๋ฆฌ์ž ๊ฐ์ฒด. ์›Œํฌํ”Œ๋กœ์šฐ ๋‚ด ์ €์žฅ ์ฒ˜๋ฆฌ์— ํ™œ์šฉ ๊ฐ€๋Šฅ


ํ™œ์šฉ ์˜ˆ์‹œ

  • ์ƒ๋‹ด ๋‚ด์šฉ, ์š”์•ฝ ๊ฒฐ๊ณผ, ์‚ฌ์šฉ์ž์˜ ์ž…๋ ฅ ๋ฐ์ดํ„ฐ ๋“ฑ์„ PostgreSQL์— ์ž๋™ ์ €์žฅ

  • ๋™์ผ SourceId ๊ธฐ์ค€์œผ๋กœ ๊ธฐ์กด ๋ฐ์ดํ„ฐ๋ฅผ upsert(๋ฎ์–ด์“ฐ๊ธฐ) ํ•˜์—ฌ ์ค‘๋ณต ๋ฐฉ์ง€

  • ํ”„๋กœ์ ํŠธ๋ณ„๋กœ Namespace๋ฅผ ๋‚˜๋ˆ„์–ด ๋ถ„๋ฆฌ๋œ ๋ฐ์ดํ„ฐ ๊ด€๋ฆฌ

  • LangChain ๊ธฐ๋ฐ˜ ์‘๋‹ต ๊ฒฐ๊ณผ๋ฅผ SQL ๊ธฐ๋ฐ˜ ๋ฆฌํฌํŠธ ์ž‘์„ฑ ์‹œ์Šคํ…œ๊ณผ ์—ฐ๋™


์‚ฌ์šฉ ํŒ

  • Namespace๋ฅผ ์ง€์ •ํ•˜๋ฉด ์—ฌ๋Ÿฌ ์›Œํฌํ”Œ๋กœ์šฐ์—์„œ ๋™์ผ ํ…Œ์ด๋ธ”์„ ๊ณต์œ ํ•˜๋ฉด์„œ๋„ ๋…ผ๋ฆฌ์  ๋ถ„๋ฆฌ๊ฐ€ ๊ฐ€๋Šฅํ•ฉ๋‹ˆ๋‹ค.

  • Cleanup์„ partial๋กœ ์„ค์ •ํ•˜๋ฉด SourceId ๊ธฐ์ค€์œผ๋กœ ์ผ๋ถ€ ๋ ˆ์ฝ”๋“œ๋งŒ ์ •๋ฆฌํ•˜์—ฌ ์œ ์—ฐํ•œ ์—…๋ฐ์ดํŠธ๊ฐ€ ๊ฐ€๋Šฅํ•ฉ๋‹ˆ๋‹ค.

  • ๋ณด์•ˆ์ด ์ค‘์š”ํ•œ ํ™˜๊ฒฝ์—์„œ๋Š” SSL ์˜ต์…˜์„ ํ™œ์„ฑํ™”ํ•˜์—ฌ ๋ฐ์ดํ„ฐ ์ „์†ก ๋ณดํ˜ธ๊ฐ€ ๊ฐ€๋Šฅํ•ฉ๋‹ˆ๋‹ค.


์ฃผ์˜์‚ฌํ•ญ

  • Connect Credential์€ WindyFlo์˜ Credential์— ๋“ฑ๋ก๋œ ์œ ํšจํ•œ PostgreSQL ์ •๋ณด์—ฌ์•ผ ํ•˜๋ฉฐ, ํ•„์ˆ˜ ํ•ญ๋ชฉ ๋ˆ„๋ฝ ์‹œ ์—ฐ๊ฒฐ ์˜ค๋ฅ˜ ๋ฐœ์ƒ

  • Cleanup์„ full๋กœ ์„ค์ •ํ•˜๋ฉด ์ง€์ •๋œ namespace์˜ ๊ธฐ์กด ๋ ˆ์ฝ”๋“œ๊ฐ€ ๋ชจ๋‘ ์‚ญ์ œ๋  ์ˆ˜ ์žˆ์œผ๋ฏ€๋กœ ์ฃผ์˜ ํ•„์š”

  • ํ…Œ์ด๋ธ” ์ƒ์„ฑ ๋˜๋Š” ํ•„๋“œ ๋ณ€๊ฒฝ์€ ์ž๋™์œผ๋กœ ์ด๋ฃจ์–ด์ง€์ง€ ์•Š์œผ๋ฏ€๋กœ ์‚ฌ์ „ DB ์„ค๊ณ„๊ฐ€ ํ•„์š”ํ•  ์ˆ˜ ์žˆ์Œ

  • SSL ์‚ฌ์šฉ ์‹œ, ์„œ๋ฒ„๊ฐ€ ์ด๋ฅผ ์ง€์›ํ•ด์•ผ ์ •์ƒ ์—ฐ๊ฒฐ ๊ฐ€๋Šฅ

Last updated