Ontwikkelaars op Sui kunnen nu gebruikmaken van sui grpc streaming om snellere en betrouwbaardere indexeringspijplijnen te bouwen voor real-time blockchain data.
Summary
Hybride streamingmodel transformeert Sui data toegang
De Sui blockchain heeft gRPC streaming geïntroduceerd als een primaire gegevensbron voor zijn indexeringsinfrastructuur, waardoor real-time checkpoint-inname met minimale latentie mogelijk is. Bovendien richt dit ontwerp zich op applicaties die moeten reageren zodra gegevens zijn afgerond.
Het platform combineert streamingmogelijkheden met traditionele pollingmethoden om gegevensnauwkeurigheid en systeemweerstand te behouden. Dit hybride model biedt directe toegang tot afgeronde checkpoints terwijl het achterwaartse compatibiliteit behoudt met bestaande aangepaste indexers die al op Sui zijn ingezet.
Het Custom Indexing Framework ondersteunt deze streaming-first architectuur zonder wijzigingen in de checkpoint-verwerkingslogica te vereisen. Teams kunnen echter nog steeds vertrouwen op hun bestaande pijplijnen terwijl ze streaming integreren waar het tastbare voordelen biedt.
Streaming verwijdert pollingvertragingen voor checkpoint-inname
De nieuwe gRPC streamingmogelijkheid verandert fundamenteel hoe indexers blockchain data ontvangen op Sui. Volledige nodes sturen nu checkpointgegevens direct naar indexers zodra finalisatie plaatsvindt, in plaats van te wachten op geplande fetches.
Dit push-gebaseerde model elimineert herhaalde pollingcycli die eerder vertragingen introduceerden tussen checkpointcreatie en downstreamverwerking. Als gevolg hiervan kunnen latentiegevoelige tools dichter bij real-time reageren zonder complexe pollingintervallen aan te passen.
Volgens de documentatie levert het systeem “real-time checkpoints zodra ze zijn afgerond” met “snellere data, veerkrachtige pijplijnen, minder infrastructuurwerk op Sui”. Dat gezegd hebbende, kunnen operators nog steeds veiligheidsnetten configureren om te beschermen tegen verbindingsproblemen en dienstonderbrekingen.
Het streamingmechanisme werkt via een eenvoudige configuratiestap waarbij ontwikkelaars een streaming-url argument toevoegen dat wijst naar een volledige node-eindpunt. De indexer ontvangt vervolgens checkpoints als gebeurtenisstromen in plaats van ze op vooraf bepaalde intervallen op te halen.
Dit gebeurtenisgestuurde model is bijzonder waardevol voor monitoringsystemen, real-time analyseplatforms en andere latentiegevoelige applicaties. Bovendien vereenvoudigt het de infrastructuur door de behoefte aan agressieve pollingstrategieën en gerelateerde operationele afstemming te verminderen.
Verplichte polling-backups beschermen historische data
Sui combineert streaming met verplichte op polling gebaseerde back-upbronnen om inherente beperkingen van langdurige verbindingen aan te pakken. Een streaminglink levert alleen gegevens vanaf het moment dat deze is opgezet, dus historische checkpoints vereisen nog steeds aanvullende mechanismen.
De General-Purpose Indexer toont dit hybride ontwerp in productie. Het gebruikt streaming als zijn primaire innamepad terwijl het pollingbronnen behoudt als veiligheidsmechanismen voor historische data en herstelscenario’s.
Deze configuratie houdt geïndexeerde gegevens actueel terwijl het schone herstarts en naadloos herstel van storingen mogelijk maakt. Als een verbinding echter wegvalt, kan het systeem hervatten vanaf het laatst bekende checkpoint met behulp van polling, en vervolgens terugkeren naar streaming zodra de link stabiliseert.
In de praktijk functioneert dit hybride patroon vergelijkbaar met een sui checkpoint streaming fallback-strategie. Ontwikkelaars verkrijgen de voordelen van lage latentie van gepushte updates zonder in te boeten op volledigheid of betrouwbaarheid.
Frameworkontwerp maakt incrementele streamingadoptie mogelijk
Het Custom Indexing Framework scheidt checkpointverwerking van gegevensinname. Indexers consumeren en transformeren checkpoints via een uniforme interface, zonder logica te koppelen aan specifieke bronnen zoals gRPC streams of HTTP polling.
Deze abstractie stelt teams in staat om inname-strategieën te ontwikkelen naarmate de vereisten veranderen, zonder kernverwerkingscomponenten opnieuw te schrijven. Bovendien houdt het codebases eenvoudiger door gegevensverwerkingslogica in een enkele laag te concentreren.
De documentatie merkt op dat met gRPC streaming, “er geen noodzaak is om te polleren, geen giswerk rond timing, en geen kunstmatige vertraging geïntroduceerd door fetch-intervallen”. Dat gezegd hebbende, kunnen operators nog steeds kiezen voor polling waar workloads geen ultra-lage latentie vereisen.
Ontwikkelaars kunnen sui grpc streaming geleidelijk inschakelen, gebaseerd op individuele workloadkenmerken. Applicaties die prioriteit geven aan gegevensversheid en real-time responsiviteit profiteren het meest van onmiddellijke streamingadoptie.
Daarentegen kunnen systemen die zich richten op batchanalyse, offline verwerking of eenvoudigere workflows doorgaan met het gebruik van alleen pollingconfiguraties. Het framework ondersteunt beide benaderingen onder hetzelfde verwerkingsmodel, wat multi-applicatieomgevingen vereenvoudigt.
Configuratie houdt logica stabiel terwijl bronnen evolueren
Bestaande aangepaste indexers gebouwd op het officiële framework vereisen minimale wijzigingen om te profiteren van streaming. Het toevoegen van gRPC-mogelijkheid omvat het opnemen van een streaming-url parameter naast de bestaande remote-store-url configuratiewaarde.
De checkpoint-verwerkingslogica blijft ongewijzigd gedurende deze overgang. Bovendien beheert het framework automatisch bronwisselingen tijdens de werking, zodat indexers een consistent beeld van de netwerkstatus behouden.
Dit ontwerp helpt veelvoorkomende storingsmodi te voorkomen waarbij systemen ofwel gegevens verliezen of aanzienlijk achterlopen op de keten. Het framework coördineert interacties tussen streaming en polling, waardoor continuïteit wordt behouden bij herstarts en netwerkonderbrekingen.
Over het algemeen biedt Sui’s hybride streaming- en pollingarchitectuur real-time checkpoints, veerkrachtige pijplijnen en een duidelijk migratiepad voor indexers die op zoek zijn naar inname met lage latentie zonder in te boeten op betrouwbaarheid.
