kazoo

    1熱度

    1回答

    我正在使用apache-zookeeper和kazoo framework作爲我的一項要求。我有一個簡單的zookeeper集羣設置,連接到服務器集羣的幾個客戶端可以讀取節點信息。我隨機地面對kazoo.exceptions.ConnectionLoss(一次五十次)。 我的擔心是什麼時候這個例外被提出?以下是我認爲的觀點。 與服務器的連接丟失 服務器沒有回超時在服務器配置中設置內做出迴應 難道還

    1熱度

    1回答

    我閱讀kazoo的文檔。 然後我在網站上運行了代碼示例,每次運行時都會調用一次該函數的func,我想阻止該程序直到刪除了一個節點的子節點,我該怎麼做? 目前代碼: #!/usr/bin/env python3 from kazoo.client import KazooClient zk = KazooClient(hosts='127.0.0.1:2181') zk.start()

    1熱度

    1回答

    現在我想要獲得ZooKeeper中指定znode的手錶數量。我已閱讀official tutorial並知道mntr命令。但它是整個QuorumServer的。 那麼ZooKeeper是否提供API來獲取指定znode的手錶數?我也在使用kazoo,我們如何獲取這些數據?

    0熱度

    1回答

    我想知道是否有人可以指點我在Django應用程序中使用kazoo的例子。我的用例是使用kazoo來檢索值列表,並在請求週期內處理它們。 任何指針將不勝感激。

    9熱度

    2回答

    我有一個非常奇怪的情況與Python Kazoo庫。我在下面的代碼中所做的是 - 當我使用kazoo庫連接到Zookeeper時,我創建了一個臨時節點,然後繼續監視其他節點,然後繼續在該節點上運行該程序無限循環..我還添加了一個監聽器,以及監視狀態。 一切工作對我來說完全沒有問題,短暫的節點到了,看我的Z序節點也工作正常... 有時候,我看到因爲連接中斷很奇怪的行爲或下降。正如我上面提到的,我添加

    0熱度

    1回答

    我的配置: 飼養員:3.4.10 操作系統:Ubuntu的16.04 蟒蛇:2.7 卡祖笛:2.3.1 我在IPython中運行的代碼: 當我重新啓動飼養員,與bin/zkServer.sh restart,外殼顯示爲下面的異常: 如果我刪除手錶和一個聽衆更換,收聽效果很好。 我不知道爲什麼,我讀了google和github/kazoo的信息,但是我沒有發現如何解決問題的解釋。 PS:有人說,因爲

    2熱度

    1回答

    我使用卡夫卡和飼養員,與他們之間建立連接,但是當我嘗試創建新卡夫卡::消費者 的連接越來越再度回落,並再次 ZOOKEEPER = '127.0.0.1:2181' CLIENT_ID = '************' TOPICS = ['*****'] @consumer = Kafka::Consumer.new(CLIENT_ID, TOPICS, zookeeper: ZOOKE

    0熱度

    1回答

    我不知道是否有在卡祖笛庫動物園管理員在連接字符串中創建chroot環境的路徑,如果路徑不存在的方式連接?有人對此有經驗嗎?我已經閱讀過文檔,但是我沒有真正發現任何可以解決這個問題的東西。 我現在正在做的是連接到服務器的飼養員,確保存在的路徑,斷開連接,然後與路徑重新連接,但這似乎並不十分有效。 connection1 = '127.0.0.102:2181,127.0.0.213:2181,127