RDF-Connect

ldes client

An LDES client that can read a stream of members from an LDES.

SHACL Validate Processor

A processor that validates incoming RDF data against a SHACL shapes graph.

rdf-connect/rml-utils-processor-ts

Collection of Typescript utilities around RML tools that includes a wrapper over the RML Mapper to be reused within the RDF-Connect ecosystem

JS/TS Template Processor

Template processor to kickstart the development of your next TypeScript RDF-Connect processor.

rdf-connect/sds-storage-writer-ts

Bucketizer processor

Simple Data Generator

Ldes Disk Writer

Writes a LDES to local files

Ldesify processor

Ldesify processor (for sds streams)

Member to Named Graph member

Transform a stream of SDS wrapped members into a named graph-based member.

Sdsify processor

Shapify processor

Stream Join processor

Handle and pipe multiple input data streams into a single output stream.

ajuvercr/mumo-pipeline

Pipeline for the MuMo project, building a LDES from data generated by custom sensors

smessie/ldes-harvester-processor-ts

RDF-Connect processor to harvest an LDES with some additional options to the ldes-client

SPARQL Ingest Processor

A processor that ingests RDF data into a SPARQL endpoint

rdf-connect/xml-utils-processors-ts

Typescript util functions related to XML including a wrapper over the Saxon-HE library to be used within the RDF-Connect ecosystem

RmlMapper

Python Log Processor

A simple Python processor to log an incoming stream to the RDF-Connect logging system.

Python Send Processor

A simple Python processor to send an array of messages to a channel.

Python Template Processor

Template processor to kickstart the development of your next Python RDF-Connect processor.

rdf-connect/osm-utils-processors-ts

RDF-Connect processors for interacting with OpenStreetMap data

GlobRead

Reads all files according to the Glob pattern

Folder Read

Reads all files inside the folder

String substitute processor

Simple string manipulation processor. Transform a stream by applying the string substitution on the messages. The matching string can be a regex.

Environment substitute processor

Substitutes all declared environment variables to their respective values.

On demand file reader processor

Reads a requested file on demand.

Unzip processor

Processor to unzip a compressed file and stream out its content.

Gunzip processor

Processor to gunzip a compressed file and stream out its content.

rdf-connect/replication-processor-ts

A processor for the RDF Connect framework that writes an incoming stream to disk and later reads it into the output stream.

Dumps To Feed Processor

A processor that converts a dump of RDF data to a feed of RDF data based on a member SHACL shape.

Buffer

HTTP Fetch processor

JS/TS Log Processor

A simple JS/TS processor to log an incoming stream to the RDF-Connect logging system.

JS/TS Send Processor

A simple JS/TS processor to send messages to a writer channel.

TestProcessor

Skolemization Processor

A processor that converts a RDF data to a skolemized form (removing blank nodes).

NodeRunner

BunRunner

JvmRunner

PyRunner

rdf-connect/orchestrator-js

rdf-connect/vienna-weather-forecast-kg-pipeline

RDF-Connect pipeline to ingest Vienna's weather forecast in a knowledge graph. This repository contains the incremental solutions for the hands-on coding session of the tutorial at SEMANTiCS 2025.

rdf-connect/ldes2sparql

RDF-Connect pipeline for materializing an LDES into a SPARQL graph store

smessie/DCAT-AP-Feeds

rdf-connect/CA-Blue-Bike-LDES

Connector Architecture-based pipeline to publish an LDES from the Blue Bike API

rdf-connect/RDF-Connect-RINF-LDES

RDF-Connect pipelines for producing and consuming a LDES from RINF data

ajuvercr/mumo-pipeline

Pipeline for the MuMo project, building a LDES from data generated by custom sensors

smessie/dcat

Export of data.gov.be in DCAT-AP

rdf-connect/example-pipelines

Collection of example pipelines for RDF-Connect grouped per programming language.

rdf-connect/marine-regions-ldes-mirror

RDF-Connect pipeline to republish a content-wise mirrored LDES for the Marine Regions dataset

rdf-connect/era-dcat-ap-feed

LDES feed for ERA's DCAT-AP metadata