Skip to main content


Showing posts with the label gtfs

GTFS Real-time Streaming with Apache NiFi

GTFS Real-time Streaming with Apache NiFi To facilitate ingesting GTFS Real-Time data, I have added a processor that converts GTFS (General Transit Feed Specification) formatted ProtoBuf data into JSON.   This is using the standard Google APIs to accomplish this.      You can see the Protocol Buffers schema here .  We will be able to get data on trip updates including delays, service alerts including changed routes and vehicle positions which can have location and congestion information.   This is the same information that these public transit systems feed to Google Maps. An Example NiFi Flow For Accessing GTFS Data First we add my new NiFi Processor, which you can get as source and build the NAR.   Or download one of the release builds of my new NiFi NAR archive.   This is alpha level code done very quickly.   If you find bugs please report and suggest updates. Once it is added to your canvas, you can change th