beltran’s gists

beltran / socket_poc.py

Created March 7, 2017 22:26

POC for socket bug


	# -- coding: utf-8 --

	import os
	import uuid
	import time

	import cassandra
	from cassandra import cluster as cassandra_cluster
	#from cassandra.io.geventreactor import GeventConnection

beltran / poc_hangs_or_grows.py

Created March 8, 2017 20:23


	# -- coding: utf-8 --

	import os
	import uuid
	import time

	import dse
	from dse import cluster as cassandra_cluster
	#from dse.io.geventreactor import GeventConnection

beltran / poc_many_prepared.py

Created March 9, 2017 00:19

Memory grows when using prepared queries and eventles, this is what's happening in endurance tests, because memory is all taken by the driver


	# -- coding: utf-8 --

	import os
	import uuid
	import time

	import dse
	from dse import cluster as cassandra_cluster
	#from dse.io.geventreactor import GeventConnection

beltran / new_poc_hangs.py

Created March 9, 2017 22:55


	# -- coding: utf-8 --

	import os
	import uuid
	import time

	import dse
	from dse import cluster as cassandra_cluster
	#from dse.io.geventreactor import GeventConnection

beltran / poc_checking_heap.py

Created March 10, 2017 20:43


	# -- coding: utf-8 --

	import os
	import uuid
	import time

	import cassandra
	from cassandra.io.libevreactor import LibevConnection
	from cassandra.cluster import Cluster

beltran / poc_timeio.py

Created March 13, 2017 19:05

TimeIO

	import logging
	from dse_graph import DseGraph
	from dse.cluster import Cluster, EXEC_PROFILE_GRAPH_DEFAULT, EXEC_PROFILE_GRAPH_ANALYTICS_DEFAULT

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

beltran / poc_trace.py

Created March 20, 2017 14:55

	from cassandra.cluster import Cluster
	import logging


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

beltran / poc_event.py

Last active March 21, 2017 19:08

	from cassandra import cluster as cassandra_cluster
	from cassandra.concurrent import execute_concurrent
	from itertools import cycle
	from threading import Event

	import logging

	log = logging.getLogger()
	log.setLevel('ERROR')
	handler = logging.StreamHandler()

beltran / poc_max_connections.py

Last active April 5, 2017 13:28

	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 = AsyncoreConnection

	if connection_class == EventletConnection:
	from eventlet import monkey_patch
	monkey_patch()

beltran / poc_keyspaced_dropped.py

Created April 5, 2017 19:32

	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 = LibevConnection

	if connection_class == EventletConnection:
	from eventlet import monkey_patch
	monkey_patch()

Jaume Marhuenda beltran