var ckan = require('dat-ckan-datastore')
var url = 'http://ackan.org/api/action/datastore_search?resource_id=id'
ckan(url).on('data', function (record) {
  // emits a data event for each record/row of your query
})

var ckan = require('dat-ckan-datastore')
 
module.exports = function (dat, ready) {
  ready()
  ckan('http://yourckanendpoint.org').pipe(dat.createWriteStream())
}