2016-03-21 2 views
0

Я хотел знать, стабильная ли потоковая передача DCP в официальном разъеме Spark Couchbase? В документах указано, что они еще не готовы к использованию в производстве. У нас есть примеры для Java?Разъем Spark Couchbase DCP

Кроме того, если кто-то может пролить некоторый свет на прецеденте, что я пытаюсь решить и есть ли искра разъем имеет смысл здесь:

Мы получаем ежедневные обновления о некоторых значках из более couchbase облегченных дб для синхронизации шлюза , Теперь, в течение 10 дней, если кто-то зарабатывает 5 или более значков, тогда нам нужно нажать поздравительный значок. Это нужно делать каждые 10 дней.

Итак, я планировал, что с помощью DCP я ежедневно проверяю изменения, запускаю задание и затем нажимаю его на шлюз синхронизации. Если в течение 10-дневного интервала было получено 5 или более значков, я подталкиваю его к шлюзу синхронизации.

Правильно ли это можно сделать или есть ли лучшие способы сделать это?

Еще одна вещь, которую можно было бы использовать это:

http://developer.couchbase.com/documentation/mobile/1.2/develop/guides/sync-gateway/server-integration/changes-worker/index.html ..

Так, какой подход лучше бы отсюда?

+0

У вас здесь два вопроса, лучше всего их разделить. –

ответ

0

DCP, передаваемый из разъема Spark, поддерживается, поскольку этот продукт является GA, и эта функция не отмечена экспериментально. Couchbase вводит функции раньше и отмечает их экспериментальные аннотации, если функция не поддерживается.

Это, я знаю, есть некоторые известные проблемы с реализацией JVM Core DCP на момент написания этой статьи, которые, как ожидается, будут исправлены в ближайшие пару недель, если не раньше. Тот, который я точно знаю, отслеживается здесь: https://issues.couchbase.com/browse/JVMCBC-312

Добавлены новые тестовые сценарии, и Couchbase работает над тем, чтобы удостовериться, что он проходит эти тесты в разных режимах отказа/перебалансировки перед следующей версией.

+0

Благодарим за отзыв. Если он будет использоваться для чтения потоков из фида изменений из шлюза синхронизации, он отслеживает номер lastSequnce i.e, до какой точки он читал? ИЛИ всегда ли он считывает все данные из ведра? – Sagar

+0

Вопрос там не совсем применим, поскольку последний порядковый номер не является понятием на уровне ковша Couchbase, только на уровне Couchbase Sync Gateway. Spark Connector использует DCP напрямую, а не Sync Gateway, который абстрагирует некоторые концепции кластера и добавляет еще несколько концепций. Подробнее см. В документах: http://developer.couchbase.com/documentation/mobile/current/develop/guides/sync-gateway/running-sync-gateway/connecting-sync-gateway-to-couchbase-server/index. .html –