දත්ත ගබඩා තාක්ෂණය දැන් ලේඛන ලියන පමණක් නොව, යෙදුම් නිර්මාණයේ සජීවිකරන සාධකයක් බවට පත්ව ඇත. Insert, Update, Delete වැනි ක්රියාකාරකම් සිදුවෙන වාරයක් මත තත්ක්ෂණික පද්ධතිවලට ඒ වෙනස්කම් රියල්-ටයිම් ලෙස ලබා දීමට Change Data Capture (CDC) නාමක පද්ධතිය භාවිතා වේ.
PostgreSQL පරිසරයේ මේ ක්රියාවලිය සක්රිය කිරීමේදී දෙකක් ප්රධාන මෙවලම් ඉදිරියට එයි – Supabase Database Webhooks සහ Prisma Pulse. දෙකම පේළි මට්ටමේ වෙනස්කම් සිදුවූ විට ඒවාය පණිවුඩයක් ලෙස පාරිභෝගික සේවා (webhooks) හෝ Prisma Client එකට ප්රවාහයක් (stream) ලෙස එවයි. නමුත් බහු-සංස්කරණ (bulk update) සිදුවූ විට “thundering herd” කියන ගැටලුව පණිවුඩ ප්රවාහයට බරක් දායි.
Supabase Webhooks කෙටි විස්තරය
Supabase හි Webhooks යනු PostgreSQL triggers සහ pg_net එක්ක සම්බන්ධ කර ඇති සරල ලේයරයක්. පේළියක් ඇතුළත්, වෙනස්, මැකී යන විට trigger එකක් ක්රියාත්මක වෙලා pg_net මගින් HTTP POST (හෝ GET) ඉල්ලීමක් පසුබැසීමේ (asynchronous) ආකාරයෙන් එවයි. එම ඉල්ලීමේ payload එකේ event type, table, schema, නව/පැරණි පේළි දත්ත ඇතුළත් වේ, නමුත් event ID එකක් නොමැති බැවින් idempotency (නැවත නැවත යැවීමේ ආරක්ෂාව) ගතකොට ගැනීමට අමාරු වේ. Supabase එකේ pg_net එකේ සීමා 200 requests/second සහ පිළිතුරු දත්ත 6 පැය පමණ පසු මකා දැමීමයි – මේවා සාමාන්ය traffic සඳහා හොඳයි, නමුත් දස දහස් ගණනක webhooks එකවර එවූ විට bottleneck එකක් බවට පත්වේ.
Prisma Pulse කෙටි විස්තරය
Prisma Pulse, push‑based webhooks නොව, PostgreSQL write‑ahead log (WAL) භාවිතා කරමින් CDC සේවාවක් ලෙස ක්රියා කරයි. ඔබගේ Prisma schema එකට සම්බන්ධ වූ නිසා, event එකේ type (create, update, delete) සහ data types සම්පූර්ණයෙන් TypeScript වලින් type‑checked වේ. ඒ නිසා column name එකක් වෙනස් කළාම, compile‑time error එකක් ලැබෙන බැවින් consumer code එකේ බග් අඩු වේ. Pulse එකේ scalability වඩාත් හොඳද? එය managed service එකක් වන නිසා, underlying infrastructure එකේ rate‑limit හෝ retry policy ගැන ඔබට සැලකිල්ලක් නොදෙයි, නමුත් bulk update සිදු කළාම, එකවර ලක්ෂ ගණනක event streaming කිරීමෙන් consumer queue එක overload වීමට ඉඩ ඇත.
“Thundering Herd” ගැටලුව කුමක්ද?
ඔබ තත්ත්වයක් හෝ batch job එකක් මගින් දස දහස් rows update කළාම, Supabase triggers හෝ Prisma Pulse streams එකවර ලක්ෂ ගණනක event පණිවුඩ එවයි. ඒවා එකම වෙබ් සේවා (webhook endpoint) හෝ consumer queue එකට එන විට, ඒ සේවා එකවර overload වීම, request timeout, retry storms වැනි ප්රශ්න ඇති කරයි. මේක “thundering herd” කියන නාමයෙන් හැඳින්වේ – බොහෝ clients එකවර “herd” වශයෙන් එකම resource එකට ඇවිත් පීඩනයක් නිර්මාණය කරයි.
ශ්රී ලංකාවට ඇති වැදගත්කම
- ඩිවෙලොපර්ලාට – Supabase හා Prisma Pulse දෙකම open‑source හා cloud‑based සේවා වන නිසා, ලංකාවේ startups සහ freelance developersට real‑time data pipelines ඉක්මනින් සකස් කිරීමේ හැකියාව ලැබේ.
- ව්යාපාරිකයන්ට – CDC භාවිතයෙන් inventory, payment, IoT sensor data වැනි තොරතුරු තත්ක්ෂණිකව නිරීක්ෂණය කර, පාරිභෝගික අත්දැකීම වඩාත් වේගවත් කරගත හැකිය.
- විද්යාල හා විශ්වවිද්යාල සිසුන්ට – Supabase triggers සහ Prisma Pulse භාවිතා කරමින් real‑time application development කුසලතා ඉගෙන ගැනීමට, cloud‑native architecture පිළිබඳ ප්රායෝගික පළපුරුද්දක් ලබාගත හැක.
ඉදිරියට, “thundering herd” ගැටලුවට queue buffering, rate‑limiting, exponential backoff වැනි pattern භාවිතා කරමින් mitigations සැලසුම් කිරීම අත්යවශ්ය වේ. ඒ නිසා, CDC තාක්ෂණය භාවිතා කරන සෑම සංවිධානයක්ම scalability සහ reliability සැලැස්වීමට අවශ්යයි.
කාලයත් සමඟ, Supabase සහ Prisma Pulse වැනි මෙවලම් තවත් ස්ථාවරව, ශ්රී ලංකාවේ තාක්ෂණික පරිසරයට නව අවස්ථා සපයයි.
