Datareplikering wf-data-replication
Princip
I samband med en Enterprise-distribution (FFDA) säkerställer datareplikering att de två databaserna Campaign-databasen (PostgreSQL) och Cloud-databasen (Snowflake) fungerar parallellt och förblir synkroniserade i realtid.
Molndatabasen (Snowflake) är optimerad för hantering av stora datagrupper, till exempel uppdatering av 1 miljon adresser. Samtidigt passar Campaigns lokala databas (PostgreSQL) bättre för åtgärder som utförs på enskilda eller små volymer, som att uppdatera en enda dirigeringsadress. Synkroniseringen sker automatiskt och transparent i bakgrunden, så att data i den lokala Campaign-databasen (PostgreSQL) dupliceras i molndatabasen (Snowflake) i realtid, vilket synkroniserar båda databaserna. Datasynkronisering innefattar scheman, tabeller och data.
➡️ Upptäck hur datareplikering fungerar i video
Replikeringslägen modes
Datareplikering kan ske i olika lägen beroende på användningsfallet.
- Replikering direkt hanterar fall där duplicering i realtid är nödvändig. Den förlitar sig på specifika tekniska trådar för att omedelbart återge data för användning som att skapa en diffusion eller uppdatera en dirigeringsadress.
- Schemalagd replikering används när omedelbar synkronisering inte krävs. Schemalagd replikering använder specifika tekniska arbetsflöden som körs varje timme för att synkronisera data, till exempel typologiregler.
Replikeringsprinciper
Replikeringsprinciper definierar hur mycket data som replikeras från en Campaign-lokal databastabell (PostgreSQL). Dessa profiler beror på tabellens storlek och det specifika användningsfallet. Vissa tabeller kommer att ha inkrementella uppdateringar när andra kommer att replikeras helt. Det finns tre huvudtyper av replikeringsprinciper:
- XS: Den här principen används för tabeller med relativt små storlekar. Hela tabellen replikeras i en bild. Med inkrementell replikering undviker du upprepade gånger samma data genom att använda en tidsstämpelpekare för att replikera endast de senaste ändringarna.
- SingleRow: Den här principen replikerar bara en rad i taget. Det används vanligtvis för direktreplikering av aktuella Campaign-objekt och relaterade objekt.
- Några rader: Den här principen är utformad för att replikera en begränsad delmängd med data med hjälp av frågedefinitioner eller filter. Det används för större tabeller där selektiv replikering är nödvändig.
Replikeringsarbetsflöden workflows
Campaign v8 förlitar sig på specifika tekniska arbetsflöden för att hantera schemalagd datareplikering. Dessa tekniska arbetsflöden är tillgängliga från noden Administration > Production > Technical workflows > Full FFDA Replication i Campaign Explorer. De får inte ändras.
Tekniska arbetsflöden kör processer eller jobb som schemaläggs regelbundet på servern. En fullständig lista över tekniska arbetsflöden finns på den här sidan.
Tekniska arbetsflöden som säkerställer datareplikering är följande:
Vid behov kan du starta datasynkronisering manuellt. Om du vill göra det högerklickar du på aktiviteten Schemaläggaren och väljer Kör väntande aktiviteter nu.
Förutom det inbyggda tekniska arbetsflödet Replikera referenstabeller kan du framtvinga datareplikering i dina arbetsflöden med någon av dessa metoder
-
Lägg till en specifik JavaScript-kodsaktivitet med följande kod:
code language-none nms.replicationStrategy.StartReplicateStagingData("dem:sampleTable")
-
Lägg till en specifik nlmodule-aktivitet med följande kommando:
code language-none nlserver ffdaReplicateStaging -stagingSchema -instance:acc1
API:er
API:er möjliggör replikering av både anpassade och körklara data från Campaign-databasen (PostgreSQL) till molndatabasen (Snowflake). Med dessa API:er kan du kringgå fördefinierade arbetsflöden och anpassa replikeringen efter specifika krav, som att replikera anpassade tabeller.
Exempel:
var dataSource = "nms:extAccount:ffda";
var xml = xtk.builder.CopyXxlData(
<params dataSource={dataSource} policy="xs">
<srcSchema name="cus:recipient"/>
</params>
);
Replikeringsköer
När stora volymer replikeringsbegäranden inträffar samtidigt kan prestandaproblem uppstå i molndatabasen (Snowflake) på grund av lås på tabellnivå under MERGE-åtgärder. För att minimera detta centraliserade arbetsflöden för replikering grupperas begäranden i köer.
Varje kö hanteras av ett tekniskt arbetsflöde, som hanterar replikering för en viss tabell och kör väntande begäranden som en enda MERGE-åtgärd. Dessa arbetsflöden aktiveras var 20:e sekund för att bearbeta nya replikeringsbegäranden:
nms:delivery.nms:dlvExclusion.nms:dlvRemoteIdRel.Replikera kön nmsTrackingUrl i samtidighet (ffdaReplicateQueueTrackingUrl_2)
nms:trackingUrl, använder två arbetsflöden för att förbättra effektiviteten genom att behandla begäranden baserat på olika prioriteringar.Självstudiekurs video
I den här videon visas de viktigaste begreppen för databaser som används i Adobe Campaign v8, varför data replikeras, vilka data som replikeras och hur replikeringsprocessen fungerar.
Ytterligare självstudiekurser för Campaign v8-klientkonsolen finns här.