Skip to content

Instantly share code, notes, and snippets.

#!/usr/bin/python
import json
import urllib2
url = 'http://192.168.3.14:9200/_cluster/health?pretty=true'
results = urllib2.urlopen(url).read()
stats = json.loads(results)
from twisted.internet import reactor
from twisted.internet.address import IPv4Address
from twisted.protocols.memcache import MemCacheProtocol
from twisted.trial.unittest import TestCase
from txconnpool.pool import PooledClientFactory, Pool
CACHE_POOL = None
class _PooledMemCacheProtocol(MemCacheProtocol):
factory = None
from twisted.internet import reactor
from twisted.protocols.memcache import MemCacheProtocol
from txconnpool.pool import PooledClientFactory, Pool
class _PooledMemCacheProtocol(MemCacheProtocol):
factory = None
def connectionMade(self):
MemCacheProtocol.connectionMade(self)

Recipe:

include_recipe "apache2::mod_python"

version = node[:graphite][:version]
pyver = node[:graphite][:python_version]

package "python-cairo-dev"
package "python-django"
14th: EST CST
21:01 - 23:30 (9:01 - 11:30) (8:01 - 10:30)
15th:
20:37 - 22:18 (8:37 - 10:18) (7:37 - 9:18)
07:00_20140115
class StatementQuery(SimpleStatement):
def __init__(self, *args, **kwargs):
cassandra_settings = getattr(settings, 'CASSANDRA', None)
consistency = ConsistencyLevel.LOCAL_QUORUM
if cassandra_settings and cassandra_settings.get('default', {}).get('DEBUG', False):
consistency = ConsistencyLevel.ONE
kwargs['consistency_level'] = kwargs.get('consistency_level', consistency)
super(StatementQuery, self).__init__(*args, **kwargs)
Python Traceback:
File "cassandra-driver/cassandra/cluster.py", line 925,\ in execute result = future.result(timeout)
File "cassandra-driver/cassandra/cluster.py", line 2068,\ in result raise self._final_exception
ReadTimeout: code=1200 [Timeout during read request] message="Operation timed out - received only 8 responses." info={'received_responses': 8, 'data_retrieved': True, 'required_responses': 9, 'consistency': 5}
$ cqlsh
virtualenv==1.10.1
# ==============================================================
# Added automatically with pip freeze:
# ==============================================================
pyserial==2.3
pycrypto==2.0.1
mercurial==2.6.2 # Updated (old version not in pip)
distribute==0.7.3 # Updated
argparse==1.2.1
demjson==1.6
ipaddress==1.0.1
mock==0.8.0
pygooglechart==0.3.0
certifi==0.0.8 # Unable to determine the version, using latest
cloudkick==0.1.0-dev # extern: "cloudkick_api"
coverage==3.5.1
datadiff==1.1.3
python-dateutil==1.5 # extern: "dateutil"
argparse==1.2.1
demjson==1.6
ipaddress==1.0.1
mock==0.8.0
pygooglechart==0.3.0
certifi==0.0.8 # Unable to determine the version, using latest
cloudkick==0.1.0-dev # extern: "cloudkick_api"
coverage==3.5.1
datadiff==1.1.3
python-dateutil==1.5 # extern: "dateutil"