Лебедь не обновил базу данных
Я хочу подписаться на Орион, чтобы отправлять уведомления Cygnus. Затем Cygnus сохранит все данные в базе данных MySQL. Я использую этот скрипт для подписки атрибута скорости car1.
(curl 130.206.118.44:1026/v1/subscribeContext -s -S --header 'Content-Type: application/json' --header 'Accept: application/json' --header 'Fiware-Service: vehicles' --header 'Fiware-ServicePath: /4wheels' -d @- | python -mjson.tool) <<EOF
{
"entities": [
{
"type": "car",
"isPattern": "false",
"id": "car1"
}
],
"attributes": [
"speed",
"oil_level"
],
"reference": "http://192.168.1.49:5050/notify",
"duration": "P1M",
"notifyConditions": [
{
"type": "ONCHANGE",
"condValues": [
"speed"
]
}
],
"throttling": "PT1S"
}
EOF
Но когда я обновляю атрибут скорости автомобиля 1, Cygnus не обновляет базу данных.
Доступные базы данных:
mysql> show databases;
+--------------------+
| Database |
+--------------------+
| information_schema |
| mysql |
| performance_schema |
+--------------------+
3 rows in set (0.00 sec)
Некоторая информация о моей службе Cygnus и конфигурации Cygnus (systemctl status cygnus
):
cygnus.service - SYSV: cygnus
Loaded: loaded (/etc/rc.d/init.d/cygnus)
Active: active (exited) since Wed 2015-10-21 17:54:07 UTC; 8min ago
Process: 31566 ExecStop=/etc/rc.d/init.d/cygnus stop (code=exited, status=0/SUCCESS)
Process: 31588 ExecStart=/etc/rc.d/init.d/cygnus start (code=exited, status=0/SUCCESS)
Oct 21 17:54:05 cygnus systemd[1]: Starting SYSV: cygnus...
Oct 21 17:54:05 cygnus su[31593]: (to cygnus) root on none
Oct 21 17:54:07 cygnus cygnus[31588]: Starting Cygnus mysql... [ OK ]
Oct 21 17:54:07 cygnus systemd[1]: Started SYSV: cygnus.
agent_mysql.conf:
# main configuration
cygnusagent.sources = http-source
cygnusagent.sinks = mysql-sink
cygnusagent.channels = mysql-channel
# source configuration
cygnusagent.sources.http-source.channels = mysql-channel
cygnusagent.sources.http-source.type = org.apache.flume.source.http.HTTPSource
cygnusagent.sources.http-source.port = 5050
cygnusagent.sources.http-source.handler = com.telefonica.iot.cygnus.handlers.OrionRestHandler
# url target
cygnusagent.sources.http-source.handler.notification_target = /notify
cygnusagent.sources.http-source.handler.default_service = def_serv
cygnusagent.sources.http-source.handler.default_service_path = def_servpath
cygnusagent.sources.http-source.handler.events_ttl = 10
cygnusagent.sources.http-source.interceptors = ts gi
cygnusagent.sources.http-source.interceptors.ts.type = timestamp
cygnusagent.sources.http-source.interceptors.gi.type = com.telefonica.iot.cygnus.interceptors.GroupingInterceptor$Builder
cygnusagent.sources.http-source.interceptors.gi.grouping_rules_conf_file = /usr/cygnus/conf/grouping_rules.conf
#Orion MysqlSink Configuration
cygnusagent.sinks.mysql-sink.channel = mysql-channel
cygnusagent.sinks.mysql-sink.type = com.telefonica.iot.cygnus.sinks.OrionMySQLSink
cygnusagent.sinks.mysql-sink.enable_grouping = false
# mysqldb ip
cygnusagent.sinks.mysql-sink.mysql_host = 127.0.0.1
# mysqldb port
cygnusagent.sinks.mysql-sink.mysql_port = 3306
cygnusagent.sinks.mysql-sink.mysql_username = root
cygnusagent.sinks.mysql-sink.mysql_password = 12345
cygnusagent.sinks.mysql-sink.attr_persistence = column
cygnusagent.sinks.mysql-sink.table_type = table-by-destination
# configuracao do canal mysql
cygnusagent.channels.mysql-channel.type = memory
cygnusagent.channels.mysql-channel.capacity = 1000
cygnusagent.channels.mysql-channel.transactionCapacity = 100
Прочитав этот вопрос, я изменил свой agent_mysql.conf в этой строке:cygnusagent.sinks.mysql-sink.attr_persistence = column
в cygnusagent.sinks.mysql-sink.attr_persistence = row
и перезапустил сервис. Затем я обновил объект orion и запросил базу данных, но ничего не произошло.
Файл журнала Cygnus: http://pastebin.com/B2FNKcVf
Примечание. Мой JAVA_HOME установлен.
1 ответ
Как видно из опубликованных вами журналов, существует проблема с файлом журнала Cygnus:
java.io.FileNotFoundException: ./logs/cygnus.log (No such file or directory)
После этого Лебедь останавливается. Вы должны проверить свою конфигурацию относительно log4j, все в /usr/cygnus/conf/log4j.properties
(он должен существовать, он создается с помощью RPM... если он не существует, поскольку он был выделен из источников вместо RPM-, он должен быть создан из доступного шаблона). Кроме того, вы можете опубликовать свой файл конфигурации экземпляра? В любом случае, с какой версией вы работаете?
РЕДАКТИРОВАТЬ 1
Недавно мы обнаружили другого пользователя, который сталкивался с той же ошибкой, и проблема заключалась в том, что /usr/cygnus/conf/log4j.properties
файл был:
flume.root.logger=INFO,LOGFILE
flume.log.dir=./log
flume.log.file=flume.log
Вместо того, что содержит шаблон:
flume.root.logger=INFO,LOGFILE
flume.log.dir=/var/log/cygnus/
flume.log.file=flume.log
После изменения это сработало, потому что RPM создает /var/log/cygnus
но нет ./log
,