Skip to content

Instantly share code, notes, and snippets.

View beltran's full-sized avatar

Jaume Marhuenda beltran

14 followers · 2 following
  • Google LLC
  • New York
View GitHub Profile
@beltran
beltran / poc_replace_but.py
Created April 5, 2017 23:29
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()
@beltran
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()
@beltran
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
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
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
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
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
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
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
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