replication-frenzy.py

#! /usr/bin/env python

import random
import time
import uuid
import couchdbkit

def server(p):
    return couchdbkit.Server("http://127.0.0.1:%s" % p)

servers = map(server, [5984, 5985, 5986])
for s in servers:
    try:
        s.delete_db("frenzy")
    except:
        pass
    s.create_db("frenzy")

for i, s1 in enumerate(servers):
    d1 = s1["frenzy"]
    for s2 in servers[i+1:]:
        d2 = s2["frenzy"]
        s1.replicate(d2.uri, d1.uri, continuous=True)
        s2.replicate(d1.uri, d2.uri, continuous=True)

doc = {"_id": "foo", "count": 0}
db = servers[0]["frenzy"]

while True:
    db.save_doc(doc)
    doc["count"] += 1