Eventium Consistency գործնականում

Eventum consistency (EC) - մոդել, որտեղ տվյալների պատճենները կարող են ժամանակավորապես տարբերվել, բայց ժամանակի ընթացքում համընկնում են առանց գլոբալ համակարգման։ Սա մեծ հասանելիության բանալին է (AP CAP) և ցածր լատենտ (PACELC), եթե ճիշտ որոշել ինվարանտները, չափման կանոնները և հաճախորդների երաշխիքները։

1) Երբ ընտրել EC (և երբ 'ոչ)

Հարմար է

Ֆիդները, պրոֆիլները, հավանումները/հաշվիչները, կոդավորումը և/որոնումը, կանխված ներկայացումները։

Գլոբալ համակարգերը տեղական ձայնագրություններով և փափուկ ինվարիաներով։

Պրոյեկտները (CQRS), որտեղ ճշմարտության աղբյուրը խիստ միջուկն է, իսկ կարդալը ասինխրոն է։

Չի համապատասխանում

Կոշտ ինվարանտներ 'գումար, միայնության, լիմիտների, կիսագնդի «չգնալ մինուս»։ Այնտեղ 'SR/ավելի ուժեղ, քան EC, sagi/TSS։

2) Տվյալների դիզայնը EC-ի տակ 'հակամարտություններ և դրանց թույլատրություն։

Սկզբունքն այն է, որ յուրաքանչյուր ձայնագրություն կրում է մետատվական տարբերակներ և դետերմինացված միաձուլման ֆունկցիա։

Ժամանակի իրականացումը/տարբերակումը '«version», «ts», «actor»։

Վեկտորի ժամացույցը 'արձանագրում են պատճառները, թույլ են տալիս հասկանալ «հակամարտող զուգահեռները»։

Մերջի կանոնները

LWW (Last-Write-International) 'պարզապես և արագ, բայց կարող է կորցնել «իմաստը»։

CRDT 'բաղադրիչ/idempotent կառուցվածքներ, երաշխավորում են համապատասխանությունը։

Հիբրիդային merge: բիզնես գործառույթը (օրինակ, միավորել ցուցակները առանց դուբլների, հաշվիչները, «նոր email + թեգերի միավորումը»)։

CRDT ընտրությունը

Հաշվարկները ՝ G-Counter/PN-Counter։

Բազմաթիվ կոմպոզիցիաներ OR-Express (առանց «կպչելու»)։

LWW-Register կոդերի գրանցումները (զգուշությամբ «կորուստների»)։

Քարտեզներ/փաստաթղթեր wwww.Map of CRDTs.

Միասին խմբագրվում է տեքստային CRDT/OT։

3) Կրկնօրինակումը և anti-entropia

Gossip/anti-entropy: պարբերական փոխանակումը հանգույցների միջև։

Hinted handoff: ժամանակավոր «տեղաբաշխումը» անհասանելի հանգույցի համար։

Read rep.ru-ը, երբ ընթերցում էին, հայտնաբերեց տարաձայնություն, բարձրացրեցին թարմ տարբերակները։

Փոփոխությունների փաթեթները (www.tas), մենք հետապնդում ենք դելտաները, ոչ թե ամբողջական նկարները։

Cvorums R/W: Մենք տեղադրում ենք "R '," W "," N "արագության և թարմության փոխզիջման տակ (օրինակ ՝" R + W> N "ավելի մոտ է strong-ին" վերջին գրառման "վրա)։

4) Հաճախորդների երաշխիքները EC-ի վերևում

Read-Your-Writes (RYW), հեղինակը իր ձայնագրությունից հետո տեսնում է այն (sticky-session/տարբերակի պիտակավորում)։

Monotonic Reads: Մենք չենք «նետում» հաճախորդին ավելի հին արժեքով (վերջին տարբերակի watermark)։

Causal Consistency: Մենք պահպանում ենք պատճառները/գործողության հոսքը (վեկտորային բջիջները վերնագրերում/հոսանքներում)։

Bounded Staleness: Երաշխիք «ոչ ավելի մեծ, քան Cort/N տարբերակները» UX քննադատական էկրանների համար։

5) UX-արտոնագրերը EC-ի համար

Լավատեսական ապդեյտներ 'ակնթարթորեն արտացոլում ենք գործողությունը' նշելով «համաժամացումը»։

Նորարարության մակնշումը 'բեյջը «նորարարված X վայրկյան», «Նորարարություն» կոճակը։

Հակամարտություն-UI 'հազվագյուտ բախումների համար' «ցույց տալ երկու տարբերակները և ընտրել/միավորել»։

Skeleton/placeholder + softrefresh: UI-ը չի արգելափակել գլոբալ կվորումի ակնկալիքով։

6) Ճարտարապետական ձևանմուշները

6. 1 CQRS + պրոյեկցիա

Write-միջուկը (CP) 'խիստ ինվարանտներ։

Read-ինքնաթիռը (EC) 'ասինխրոն պրոյեկտներ, ինդեքսներ, քեշներ։ թույլ տվեք։

6. 2 Մուլտֆիլմի շրջան AP

Գրառումները տեղական արագ են, ասինխրոն կրկնօրինակումը։

Geo-partitioning: տվյալները «ապրում են» ավելի մոտ օգտագործողին։ Քրոս շրջան - ագրեգատներ։

CRDT/merge գործառույթները հեռացնում են հակամարտությունների ցավը։

6. 3 Քվորումային կարգավորում

yaml consistency:
replicas: 3 # N write_quorum: 2 # W read_quorum: 2 # R => R + W> N, closer to freshness on "last record"
read_repair: true hinted_handoff: true

7) Տարբերակման և merge (օրինակ)

yaml entity: "profile"
versioning:
clock: "vector"    # или "hybrid_time"
fields:
name:   { merge: "lww" }
emails:  { merge: "set_union" }   # OR-Set tags:   { merge: "or_set" }
likes:   { merge: "pn_counter" }
conflict_ui:
enabled: true show_diff_for: ["name"]
auto_merge_for: ["emails","tags","likes"]

8) EC-ի դիտարկումը 'ինչ չափել

Staleness Age (p50/p95/p99): «now medical _ version _ ts» կամ «հրաժարականի տարբերակների քանակը»։

Replant Lag 'տարածաշրջանի/հանգույցների միջև առաքման ուշացում։

Sylict Rate-ը զուգահեռ ապդեյտների մասն է, բաշխումը տիպերով։

Read-Repert Rate/Latency: Որքան հաճախ և արագ «բուժենք» կարդալիս։

Convergence Time: ժամանակն է նախքան ձայնագրությունները բարձրացնելուց/հանգույցի ձախողումից հետո։

Սեմանտիկ SLO: «95 տոկոսը ավելի մեծ է, քան 2s», «99 տոկոսը ֆիդան համընկնում է <10s»։

9) Runbook-ը և միջադեպերը

Սցենարներ

1. Lag միջմայրցամաքային աճը 'նվազեցնել «write fan-out», ներառել ագրեսիվ read-rep.ru, ծանր գրողներ։

2. Հակամարտությունների աճը 'ժամանակավորապես ներառել ավելի «խիստ» կանոնը (օրինակ, causal/RYW), սահմանափակել մրցակցային ապդեյտները տաք բեկորների վրա։

3. Պրոյեկցիաների հետաձգումը 'գերակայել վերարտադրման գծերը, ժամանակավորապես կրճատել ոչ կրիտիկական ապդեյտների հաճախությունը։

4. Տվյալները «սեղմեցին» հանգույցների մի մասի մոտ 'ֆորս-անտի-էնտրոպիա, կուսակցության ռեբալանս, hinted handoff աուդիտ։

5. Ձեռքի վերլուծություն 'կոնֆլիկտային շարժիչների բեռնումը, «merge-medview» գործիքը, բատչային ֆիքսը։

10) EC թեստավորում

Jepsen-նման թեստեր 'ցանցի բաժանումը, clock-skew, կրկնվող գրառումներ։

Property-based: invararants merge գործառույթներ (լոկոմոտիվություն, գաղափարախոսություն, ասոցիացիա)։

Fuzz-կոնֆլիկտներ 'զուգահեռ ապդեյտները մեկ բանալին' առաքման փոփոխական կարգի հետ։

Ծանրաբեռնված «սղոցները» 'փոթորիկների փոփոխությունը/լռությունը Time convergence-ի գնահատման համար։

UX-սիմվոլը 'RYW/monotonic տեսանելիությունը բնորոշ սցենարներում։

11) Multi-tenant-ը և պլանները

Թեգերը 'tenrone _ id/plan/region' իրադարձությունների/ձայնագրությունների մեջ։

Fairness: limits/reportper tenae, որպեսզի «աղմկոտ» հաճախորդը չաճի ընդհանուր staleness։

Residency: Տվյալները և դրանց կրկնօրինակները իրավասության սահմաններում։ Քրոս-տարածաշրջանային ներկայացումները միայն ագրեգատներն են։

12) Տիպիկ սխալներ

LWW «ամեն ինչի համար»։ Կորցնում է իմաստալից զուգահեռ փոփոխությունները։ օգտագործեք CRDT/ստացիոնար merge։

Հաճախորդների երաշխիքներ չկան։ Օգտագործողը «չի տեսնում» սեփական ձայնագրությունը վստահության կորուստ։

Չափման բացակայությունը հնացած է։ Չկա staleness/lag/« թաքնված դեգրադացիա »։

Dance-write-ը տարբեր համակարգերում առանց merge-ի։ Ֆանտոմներն ու տարբերությունները անվերջ են։

Համաշխարհային կարգը ցանկացած գնով։ Ավելորդ կվորումները սպանում են p95-ը, իսկ բիզնեսը բավականին բարդ է։

13) Արագ բաղադրատոմսեր

Ֆիդ/ժապավենը ՝ EC + causal/RYW հեղինակի համար, CRDT ռեակցիաների համար, staleness p95 242-5s։

Պրոֆիլի/105: bounded staleness (351-2s), RYW, ստացիոնար merge (հավաքածուների union)։

Գլոբալ կատալոգը 'geo-part.ru, ասինխրոն կրկնօրինակումը, read-rep.ru-ի խնդրանքով, հակամարտությունները OR-Express-ի միջոցով։

Մետրիկները/հաշվիչները ՝ PN-Counter, համախմբումը ֆոնի վրա։ նշանով «մոտավոր» արժեքներ։

14) Մինի-ստանդարտ (բանավոր սխեմա)

Write-edge: Տեղական ձայնագրությունը տարբերակով («vector/hybrid»), իրադարձությունների ամսագիր։

Replication: очереди + gossip/anti-entropy, hinted handoff.

Storage: Նվագարկումը բանալին, CRDT/merge գործառույթները ձայնագրման մակարդակում։

Read-plane: cashi read-rep.ru, RYW/monotonic-ը, bounded staleness քննադատական էկրանների համար։

Observability: lagi/հնացած/կոնֆլիկտներ, SLO steilness-ի ավելցուկ ալերտներ։

15) Չեկ թուղթ մինչև վաճառելը

• Հստակ նկարագրվում է ինվարանտները և որտեղ նշված EC-ն։
• Ընտրվել է տարբերակումը (vector/hybrid) և դետերմինացված գործառույթները merge/CRDT։
• Իրականացվում են հաճախորդների երաշխիքներ (RYW/monotonic/causal) քննադատական UX-ի համար։
• read-rep.ru, hinted handoff; Կվորներ R/W փաստաթղթավորված են։
• Staleness/lag/convergence և ալտերտերը p95/p99 շեմերի վրա։
• Runbook "և հակամարտությունների/բայերի աճի վրա։ ձեռքի գործիքներ։
• Ցանցային բաժանման թեստեր, զուգահեռ ապդեյտներ և նմանության հատկություն։
• Multi-tenant լիմիթները և residency-քաղաքականությունը հաշվի են առնվում։
• UX-ներարկիչները թարմ և fallback վարքագիծը համաձայնեցված են արտադրանքի հետ։

Եզրակացություն

Eventium consistency-ը ոչ թե «փոխզիջում փոխզիջման համար», այլ մեծացման և հասանելիության գործիք։ Եթե դուք ձևավորում եք invariants, ընտրեք ճիշտ merge գործառույթները (ցանկալի է CRDT, որտեղ դա տեղին է), տվեք հաճախորդների երաշխիքներ և չափեք steylnations-ը, համակարգը կլինի արագ, կայուն և ազնիվ, ինչպես նաև օգտագործողների և բիզնեսի համար։