Как заполнить Cygnus.conf

Несколько дней назад мне удалось запустить cygnus на моем Context Broker vm, как говорится в документации. Все подписки между cygnus и CB проходят без проблем, а уведомления, которые отправляет CB, доходят до cygnus.

Я сомневаюсь, что когда мне придется настраивать cygnus.conf, я думаю, что сбои, которые у меня возникают, когда Cygnus отправляет данные в COSMOS, связаны с конфигурацией полей этого архива. Следующий файл — это шаблон для заполнения, доступный в документации:

### ============================================
###OrionHDFSSink configuration
###channel name from where to read notification events
cygnusagent.sinks.hdfs-sink.channel = hdfs-channel
### sink class, must not be changed
cygnusagent.sinks.hdfs-sink.type = es.tid.fiware.fiwareconnectors.cygnus.sinks.OrionHDFSSink
### Comma-separated list of FQDN/IP address regarding the Cosmos Namenode endpoints
cygnusagent.sinks.hdfs-sink.cosmos_host = x1.y1.z1.w1,x2.y2.z2.w2
###port of the Cosmos service listening for persistence operations; 14000 for httpfs, 50070 for webhdfs and free choice for inifinty
cygnusagent.sinks.hdfs-sink.cosmos_port = 14000
###default username allowed to write in HDFS
cygnusagent.sinks.hdfs-sink.cosmos_default_username = default
###default password for the default username
cygnusagent.sinks.hdfs-sink.cosmos_default_password = xxxxxxxxxxxxx
###HDFS backend type (webhdfs, httpfs or infinity)
cygnusagent.sinks.hdfs-sink.hdfs_api = httpfs
### how the attributes are stored, either per row either per column (row, column)
cygnusagent.sinks.hdfs-sink.attr_persistence = column
###Hive FQDN/IP address of the Hive server
cygnusagent.sinks.hdfs-sink.hive_host = x.y.z.w
### Hive port for Hive external table provisioning
cygnusagent.sinks.hdfs-sink.hive_port = 10000

### ============================================

Но для меня не ясно, какое направление я должен указать в следующем поле:

### Comma-separated list of FQDN/IP address regarding the Cosmos Namenode endpoints
cygnusagent.sinks.hdfs-sink.cosmos_host = x1.y1.z1.w1,x2.y2.z2.w2

и я также не знаю, совпадает ли поле сервера улья, направление, которое мне нужно написать, с IP-адресом экземпляра fiware COSMOS:

### Hive FQDN/IP address of the Hive server
cygnusagent.sinks.hdfs-sink.hive_host = x.y.z.w

person Mest    schedule 26.11.2014    source источник


Ответы (1)


Просмотрите Краткую документацию по BigData , кажется, что значение для cosmos_host в случае использования экземпляра FIWARE Lab Cosmos будет следующим: Cosmos.lab.fi-ware.org.

О Улье сказано:

Или удаленно, разработав клиент Hive (как правило, с использованием JDBC, но есть и другие варианты для других языков программирования, отличных от Java), подключившись к spaces.lab.fi-ware.org:10000.

поэтому я предполагаю, что hive_host такой же (cosmos.lab.fi-ware.org).

Наконец, примите во внимание следующее:

Кроме того, все задокументированные подключения к такому глобальному экземпляру (за исключением подключений ssh ​​и портала Cosmos) должны выполняться с виртуальной машины FI-LAB; напротив, брандмауэр их остановит.

это означает, что вы должны запускать Cygnus с виртуальной машины внутри FIWARE Lab.

person fgalan    schedule 26.11.2014
comment
После этого у меня все еще есть эта проблема: [ERROR - es.tid.fiware.fiwareconnectors.cygnus.sinks.OrionSink.process(OrionSink.java:140)] Persistence error (The default_org/XYZ directory could not be created in HDFS. HttpFS response: 400 Bad Request) - person Mest; 16.01.2015
comment
(Машина Cygnus находится в виртуальной машине внутри FiwareLab и использует этот hive_host) - person Mest; 16.01.2015
comment
Если это новая ошибка, я бы предложил открыть новый вопрос об этом, чтобы не засорять темы. - person fgalan; 16.01.2015