yoIan.js

var Dyno = require('dyno');
var trizilla = require('trizilla')();
var tilebelt = require('tilebelt');
var args = require('minimist')(process.argv.slice(2));

var jobTile = JSON.parse(args._[0]);

var decompressType = args._[1] || 'Decompressor';

var jobKey = tilebelt.tileToQuadkey(jobTile);

var config = {
  region: 'local',
  endpoint: 'http://localhost:4567',
  table: 'weather-lattice'
};

var dyno = Dyno(config);

var scanner = require('../lib/scan-handler')();
var queryOptions = {
    id: {'EQ': jobKey }
}

dyno.query(queryOptions, {limit: 100})
  .pipe(scanner.handleScan())
  .pipe(trizilla.decompress(decompressType))
  .pipe(process.stdout);