ingest-pipeline

Various examples using the Elasticsearch Ingest node pipelines

Elasticseach ingest processor to add Chinese region info based on provided ip address

Elasticsearch ingest pipeline for ASUS ROG router syslog in Security Onion 3.1

Super-ingest + RAG console — feed it documents; it grows a thicket: dense, interconnected, searchable.

CLI tooling for ingesting structured JSONL triples into a Virtuoso OpenSource instance via TTLP_MT. JSONL→N-Triples converter in Go with nested-object, array, RDF/JS typed-node, and unicode support.

Ingest pipelines to parse Artifactory logs sent to Elasticsearch using Filebeat

IP2Location Processor for Elasticseach Ingest Pipeline to get geolocation information such as country, state, city, latitude, longitude, ZIP code, time zone, ISP, domain name, connection speed, IDD code, area code, weather station code, weather station name, MNC, MCC, mobile brand, elevation and usage type by IP address.

Benchmark supervised ML model in ingest pipeline

Python service that chunks checkout, fulfillment, receipt, and order-update documents, embeds them, and upserts them into a vector collection.

Visually diagrams Elasticsearch ingest pipelines using Python and Graphviz

Geocode city and country names at ingest time in Elasticsearch, using the GeoNames dataset and an enrich policy. No external geocoding API needed. Includes a Kibana Maps demo.