Steg 2: anslut skrapkällor och batchbearbetning

Bygg listan över regulatoriska källor och iterera igenom varje URL en i taget.

1. I Assemble Source List ställer ni in JavaScript Code till den konfigurerade listan med URL:er, t.ex. https://www.sec.gov/news/pressreleases, https://www.fca.org.uk/news och https://www.esma.europa.eu/press-news/esma-news.
2. Koppla Assemble Source List till Batch Source Iterator för att iterera igenom varje källa.
3. Lämna Batch Source Iterator med standardinställningar (inga ändringar behövs).

Steg 3: skrapa regulatoriska sidor och slå ihop resultat

Skrapa varje sida efter uppdateringar och kombinera sedan utdata för vidare bearbetning.

1. I Regulatory Page Scraper ställer ni in User Prompt till Extract all recent regulatory news items from the page. For each item return JSON with: title, date, summary, url, sourceName = "{{$json.source}}". Limit to the first 10 items..
2. Ställ in Website URL till {{ $json.url }} så att varje batchobjekt skrapas.
3. Koppla Regulatory Page Scraper till Combine Scrape Outputs (två indata) och till Failure Capture Logic parallellt.
4. Ställ in Combine Scrape Outputs till Mode combine för att konsolidera skrapresultaten.

Regulatory Page Scraper skickar utdata till både Combine Scrape Outputs (två indata) och Failure Capture Logic parallellt.

Steg 4: normalisera, avduplicera och förgrena parallellt

Normalisera den skrapade datan, tagga kritiska uppdateringar och dela flödet för både avisering och lagring.

1. I Normalize and De-dup behåller ni det medföljande normaliseringsskriptet (lägger till dedupId, isImportant, scrapedAt och source).
2. Koppla Combine Scrape Outputs till Normalize and De-dup.
3. I Check Critical Update ställer ni in det booleska villkoret till Value 1 {{ $json.isImportant }} med Operation true.
4. I Store Record in Redis ställer ni in Operation till set, Key till {{ 'reg_update:' + $json.dedupId }}, Value till {{ JSON.stringify($json) }} och TTL till 604800 med Expire aktiverat.

Normalize and De-dup skickar utdata till både Check Critical Update och Store Record in Redis parallellt.

Steg 5: konfigurera Telegram-aviseringar

Formatera en Telegram-avisering för kritiska uppdateringar och skicka den till den chatt ni har valt.

1. Koppla Check Critical Update till Compose Telegram Notice.
2. I Compose Telegram Notice lämnar ni Options som standard (konfigurera fält om ni vill bygga en anpassad text-payload).
3. I Dispatch Telegram Alert ställer ni in Text till {{ $json.text }} och Chat ID till {{ $env.TELEGRAM_CHAT_ID || 'YOUR_CHAT_ID' }}.
4. Behåll Parse Mode som Markdown och Disable Notification som false.

Steg 6: testa och aktivera ert arbetsflöde

Validera körningen från början till slut och aktivera sedan arbetsflödet för löpande användning.

1. Klicka på Execute Workflow från Manual Launch Trigger för att köra ett fullständigt test.
2. Verifiera att Combine Scrape Outputs och Normalize and De-dup ger strukturerade objekt med fälten dedupId och isImportant.
3. Bekräfta att kritiska objekt passerar genom Check Critical Update och når Dispatch Telegram Alert med en giltig text-payload.
4. Kontrollera er Redis-instans för att bekräfta att poster skrivs med nycklar som reg_update:*.
5. När allt är validerat växlar ni arbetsflödet till Active för att aktivera produktionsanvändning.