poc_replace_but.py

from cassandra.io.eventletreactor import EventletConnection
from cassandra.io.geventreactor import GeventConnection
from cassandra.io.libevreactor import LibevConnection
from cassandra.io.asyncorereactor import AsyncoreConnection

connection_class = GeventConnection

if connection_class == EventletConnection:
    from eventlet import monkey_patch
    monkey_patch()
elif connection_class == GeventConnection:
    import gevent.monkey
    gevent.monkey.patch_all()

from cassandra.cluster import Cluster


import logging
import time

log = logging.getLogger()
log.setLevel('DEBUG')
handler = logging.StreamHandler()
handler.setFormatter(logging.Formatter("%(asctime)s [%(levelname)s] %(name)s: %(message)s"))
log.addHandler(handler)


KEYSPACE = "testkeyspace"


cluster = Cluster(['127.0.0.1'], connection_class=connection_class)
session = cluster.connect()

while 1:
    try:
        log.info("Executing select in main")
        future = session.execute("SELECT * FROM system.hints")

    except:
        pass
    time.sleep(3)