BlueBike_pipeline.ttl

@prefix js: <https://w3id.org/conn/js#> .
@prefix : <https://w3id.org/conn#> .
@prefix owl: <http://www.w3.org/2002/07/owl#> .
@prefix rdfs: <http://www.w3.org/2000/01/rdf-schema#> .
@prefix rml: <https://w3id.org/conn/rml#> .

<> owl:imports <https://raw.githubusercontent.com/TREEcg/connector-architecture/main/channel/file.ttl>.
<> owl:imports <./processor/rml-mapper-processor-ts/rmlMapper.ttl>.
<> owl:imports <./processor/sds-processors/configs/sdsify.ttl>.
<> owl:imports <./processor/sds-storage-writer-mongo/step.ttl>.

#### Channels

[] a js:JsChannel;
  :reader <ld/reader-js>;
  :writer <ld/writer-js>.

<ld/reader-js> a :JsReaderChannel.
<ld/writer-js> a :JsWriterChannel.

[] a js:JsChannel;
  :reader <sds/reader-js>;
  :writer <sds/writer-js>.

<sds/reader-js> a :JsReaderChannel.
<sds/writer-js> a :JsWriterChannel.

<metadata/in> a :FileReaderChannel;
  :fileReadFirstContent "true";
  :fileOnReplace "true";
  :filePath <./metadataIn.ttl>.

#### Processors

[] a js:RmlMapperString;
  js:rml_mapping_location <./bluebike.rml.ttl>;
  js:rml_data_output <ld/writer-js>;
  rml:jarFile <./rmlmapper-6.2.0-r368-all.jar>;
  js:cron "*/15 * * * * *".

[] a js:Sdsify;
  js:input <ld/reader-js>;
  js:output <sds/writer-js>;
  js:stream <https://w3id.org/sds#Stream>;
  js:objectType <https://purl.eu/ns/mobility/passenger-transport-hubs#ResourceReport>.

[] a js:Ingest;
  js:dataInput <sds/reader-js>;
  js:metadataInput <metadata/in>;
  js:metadataCollection "BLUEBIKE_META";
  js:dataCollection "BLUEBIKE_DATA";
  js:indexCollection "BLUEBIKE_INDEX";
  js:databaseUrl "mongodb://localhost:27017/ldes";
  js:pageSize 100.