Головна / NATS Pipeline
Моніторинг NATS & Pipeline
Stream PIM_EVENTS · FastStream + ARQ
Stream
PIM_EVENTS
JetStream
max_ack_pending
20
gemini backpressure
Subjects
4
raw→…→published
PIM feeds
9
hourly cron
Saleor
off
post-MVP
Topology JetStream & FastStream
КРОК 01
ARQ Scanner
hash-diff · 5 хв · offerable pool
КРОК 02
cat_mapping_workers
Ollama bge-m3 + pgvector
КРОК 03
gemini_workers
Gemini Flash · max_ack_pending=20
КРОК 04
quality_gate_workers
score ≥ 80 → auto_approved
КРОК 05
saleor_sync_workers
MVP no-op · post-MVP GraphQL
| Consumer | Queue group | Status |
|---|---|---|
| cat_mapper_consumer | cat_mapping_workers | active |
| gemini_enricher_consumer | gemini_workers | throttle ok |
| quality_gate_consumer | quality_gate_workers | active |
| saleor_sync_consumer | saleor_sync_workers | deferred |