cygnus-ngsi.sources = http-source

cygnus-ngsi.sinks = postgresql-sink
cygnus-ngsi.channels = postgresql-channel

cygnus-ngsi.sources.http-source.type = org.apache.flume.source.http.HTTPSource
cygnus-ngsi.sources.http-source.channels = postgresql-channel
cygnus-ngsi.sources.http-source.port = 5050
cygnus-ngsi.sources.http-source.handler = com.telefonica.iot.cygnus.handlers.NGSIRestHandler
cygnus-ngsi.sources.http-source.handler.notification_target = /notify
cygnus-ngsi.sources.http-source.handler.default_service = default
cygnus-ngsi.sources.http-source.handler.default_service_path = /
cygnus-ngsi.sources.http-source.interceptors = ts gi
cygnus-ngsi.sources.http-source.interceptors.ts.type = timestamp
cygnus-ngsi.sources.http-source.interceptors.gi.type = com.telefonica.iot.cygnus.interceptors.NGSIGroupingInterceptor$Builder
cygnus-ngsi.sources.http-source.interceptors.gi.grouping_rules_conf_file = /opt/apache-flume/conf/grouping_rules.conf

cygnus-ngsi.sinks.postgresql-sink.type = com.telefonica.iot.cygnus.sinks.NGSIPostgreSQLSink
cygnus-ngsi.sinks.postgresql-sink.channel = postgresql-channel
cygnus-ngsi.sinks.postgresql-sink.enable_encoding = false
cygnus-ngsi.sinks.postgresql-sink.enable_grouping = false
cygnus-ngsi.sinks.postgresql-sink.enable_lowercase = false
cygnus-ngsi.sinks.postgresql-sink.enable_name_mappings = false
cygnus-ngsi.sinks.postgresql-sink.data_model = dm-by-entity
cygnus-ngsi.sinks.postgresql-sink.postgresql_host = my_host_ip
cygnus-ngsi.sinks.postgresql-sink.postgresql_port = my_postgresql_port
cygnus-ngsi.sinks.postgresql-sink.postgresql_database = my_db
cygnus-ngsi.sinks.postgresql-sink.postgresql_username = user
cygnus-ngsi.sinks.postgresql-sink.postgresql_password = pass
cygnus-ngsi.sinks.postgresql-sink.attr_persistence = row
cygnus-ngsi.sinks.postgresql-sink.batch_size = 100
cygnus-ngsi.sinks.postgresql-sink.batch_timeout = 30
cygnus-ngsi.sinks.postgresql-sink.batch_ttl = 10
cygnus-ngsi.sinks.postgresql-sink.batch_retry_intervals = 5000
cygnus-ngsi.sinks.postgresql.backend.enable_cache = true

cygnus-ngsi.channels.postgresql-channel.type = com.telefonica.iot.cygnus.channels.CygnusMemoryChannel
cygnus-ngsi.channels.postgresql-channel.capacity = 10000
cygnus-ngsi.channels.postgresql-channel.transactionCapacity = 1000

time=2018-02-07T17:07:21.921Z | lvl=INFO | corr=56410918-0c29-11e8-ae44-0242ac110003 | trans=e5444289-3da3-4eed-90f8-f096679693c5 | srv=howtoservice | subsrv=/howto | comp=cygnus-ngsi | op=persistAggregation | msg=com.telefonica.iot.cygnus.sinks.NGSIPostgreSQLSink[490] : [postgresql-sink] Persisting data at NGSIPostgreSQLSink. Schema (howtoservice), Table (howto_187a93090d37_thing), Fields ((recvTimeTs,recvTime,fiwareServicePath,entityId,entityType,attrName,attrType,attrValue,attrMd)), Values (('1518023231518','2018-02-07T17:07:11.518Z','/howto','187A93090D37','Thing','TimeInstant','ISO8601','2018-02-05T13:09:54.525Z','[]'),('1518023231518','2018-02-07T17:07:11.518Z','/howto','187A93090D37','Thing','glucose','Float','46','[]'),('1518023231518','2018-02-07T17:07:11.518Z','/howto','187A93090D37','Thing','location','geo:point','60.168, 24.940','[{"name":"TimeInstant","type":"ISO8601","value":"2018-02-05T13:09:54.525Z"}]'))
time=2018-02-07T17:07:21.921Z | lvl=ERROR | corr=56410918-0c29-11e8-ae44-0242ac110003 | trans=e5444289-3da3-4eed-90f8-f096679693c5 | srv=howtoservice | subsrv=/howto | comp=cygnus-ngsi | op=processNewBatches | msg=com.telefonica.iot.cygnus.sinks.NGSISink[569] : CygnusPersistenceError. -, null. Stack trace: [com.telefonica.iot.cygnus.sinks.NGSIPostgreSQLSink.persistAggregation(NGSIPostgreSQLSink.java:504), com.telefonica.iot.cygnus.sinks.NGSIPostgreSQLSink.persistBatch(NGSIPostgreSQLSink.java:231), com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:558), com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:370), org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68), org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147), java.lang.Thread.run(Thread.java:748)]