как вы декодируете protobufs gtfs в узле

Я продолжал находить ваш вопрос, когда искал ту же проблему, что и у вас, и, надеюсь, я смогу помочь кому-то еще. После поиска в Интернете намного дольше, чем я должен был, я придумал кое-что, что работает. Я не совсем понимал данные, пока не расшифровал рабочий канал.

В значительной степени кажется, что это связано с тем, как данные считываются. Я не человек NodeJS, поэтому я не знаю, почему, но это зависит от того, как данные читаются с помощью http, а не request для декодирования. Я не мог заставить тот же метод работать с request для данных.

Часть этого я нашел из https://github.com/dcodeIO/ProtoBuf.js/wiki/How-to-read-binary-data-in-the-browser-or-under-node.js.%3F но я еще не совсем понял, как использовать protobufjs, поэтому привожу здесь рабочий пример для других. Надеюсь, поможет.

var ProtoBuf = require('protobufjs');
var http = require("http");

// create a protobuf decoder
var transit = ProtoBuf.protoFromFile('gtfs-realtime.proto').build('transit_realtime');
// your protobuf binary feed URL
var feedUrl = "...";    

// HTTP GET the binary feed
http.get(feedUrl, parse);

// process the feed
function parse(res) {
    // gather the data chunks into a list
    var data = [];
    res.on("data", function(chunk) {
        data.push(chunk);
    });
    res.on("end", function() {
        // merge the data to one buffer, since it's in a list
        data = Buffer.concat(data);
        // create a FeedMessage object by decooding the data with the protobuf object
        var msg = transit.FeedMessage.decode(data);
        // do whatever with the object
        console.log(msg);
    }); 
});

Я смог заставить это работать (во всяком случае, с нью-йоркскими каналами MTA), заставив модуль request иметь нулевую кодировку, таким образом гарантируя, что он возвращает буфер вместо строки. Вот так:

request({
    url: 'http://developer.trimet.org/ws/V1/FeedSpecAlerts/?appID=618F30BB3062F39AF24AED9EC'
    encoding: null
}, parse)

Тогда синтаксический анализ работает нормально.

Со страницы разработчиков Google по адресу developers.google.com/transit/gtfs-realtime. /образцы кода. Google теперь сделал доступным модуль Node.js npm, чтобы упростить задачу:

npm install gtfs-realtime-bindings

Вот фрагмент кода Google ( Лицензия Apache 2.0)

var GtfsRealtimeBindings = require('gtfs-realtime-bindings');
var request = require('request');

var requestSettings = {
  method: 'GET',
  url: 'URL OF YOUR GTFS-REALTIME SOURCE GOES HERE',
  encoding: null
};
request(requestSettings, function (error, response, body) {
  if (!error && response.statusCode == 200) {
    var feed = GtfsRealtimeBindings.FeedMessage.decode(body);
    feed.entity.forEach(function(entity) {
      if (entity.trip_update) {
        console.log(entity.trip_update);
      }
    });
  }
});

Это не решает вашу проблему, но вы можете получить RT-канал в текстовом виде, используя URL-адрес, например http://developer.trimet.org/ws/V1/FeedSpecAlerts/appid/618F30BB3062F39AF24AED9EC/text/true

Также взгляните на модуль node-gtfs.

Я не эксперт по узлам, но тип корневого сообщения фида GTFS в реальном времени — «FeedMessage»:

https://developers.google.com/transit/gtfs-realtime/reference

Кажется, вы пытаетесь проанализировать канал как сообщение «Предупреждение»:

console.log(transit.Alert.decode(res.body))

Может быть, попробовать изменить Alert на FeedMessage и посмотреть, что произойдет?