Articles of cassandra

Cassandra cqlsh “no se puede conectar a ningún servidor”

Recibo el siguiente mensaje al ejecutar cqlsh.bat en la línea de comandos Connection error: (‘Unable to connect to any servers’, {‘127.0.0.1’: ProtocolError(“cql_version ‘3.3.0’ is not supported by remote (w/ native protocol). Supported versions: [u’3.2.0′]”,)}) Estoy ejecutando Python versión 2.7.10 junto con Cassandra versión 2.2.1. No estoy seguro de si está relacionado, pero cuando inicio el […]

¿La mejor biblioteca / envoltorio de Cassandra para Python?

Encontré lazyboy y pycassa , tal vez hay otros también. He visto muchos sitios que recomiendan a lazyboy. En mi humilde opinión, el proyecto parece muerto, vea https://www.ohloh.net/p/compare?project_0=pycassa&project_1=lazyboy Entonces, ¿cuál es la mejor opción para un nuevo proyecto? Gracias.

Reutilización de la sesión de la base de datos Cassandra en AWS Lambda (python)

Estoy tratando de reutilizar una sesión de clúster de Cassandra para las siguientes llamadas a la función de AWS Lambda. Lo he implementado con éxito en Java, pero al reutilizar la sesión en python se agota el tiempo de espera de la invocación lambda (la primera llamada que realiza la inicialización está bien). Desde los […]

Verifique si existe un registro en una tabla de Cassandra usando el controlador Python

¿Cómo se puede determinar si existe un registro en una tabla? La forma en que lo intenté fue hacer una consulta SELECT y luego contar las filas del ResultSet usando lo siguiente: rows = session.execute(“SELECT * FROM test_table WHERE id=%s”, ([])) if len(rows) == 0: print “Does not exist” Sin embargo, ResultSet no admite len […]

Descriptor de archivo de inundación de TimeRID de Cassandra cuando se usa uuid en forma predeterminada

Tengo el modelo de Cassandra como import uuid from cassandra.cqlengine import columns from cassandra.cqlengine.models import Model class MyModel(Model): … … created_at = columns.TimeUUID(primary_key=True, clustering_order=’DESC’, default=uuid.uuid1) … … La aplicación uuid1 de forma recentrada no cierra los archivos: alcanza el límite del descriptor de archivos . Intento encontrar la solución, pero parece que las opciones creo […]

¿Cómo puedo lograr el rendimiento de 50 k / s al insertar mis datos en Cassandra mientras leo la entrada de un archivo csv?

Mi objective es boost el rendimiento de los datos de versiones en Cassandra. He usado lecturas y escrituras concurrentes y también he aumentado el tamaño de trozo que mi código lee en el archivo. Mi máquina es de 16 gb con 8 núcleos y sí, he cambiado el archivo yaml de Cassandra para 10k lecturas […]

Django con base de datos NoSQL

Estoy trabajando con una aplicación Django que usa la versión Django 1.8 . La mayoría de los datos con los que tratamos son de formato JSON. Estamos tratando de implementar cualquier base de datos NoSQL . Pero veo que MONGODB no es compatible con la versión 1.8 o superior y ¿hay alguna base de datos […]

No se puede conectar a Cassandra de forma remota con el controlador DataStax Python

Tengo problemas para conectarme a Cassandra (que se ejecuta en un nodo EC2) de forma remota (desde mi computadora portátil). Cuando uso el controlador DataStax Python para Cassandra: from cassandra.cluster import Cluster cluster = Cluster([’10.XXX’], port=9042) cluster.connect() Yo obtengo: Traceback (most recent call last): File “/Users/user/virtualenvs/test/lib/python2.7/site-packages/IPython/core/interactiveshell.py”, line 3035, in run_code exec(code_obj, self.user_global_ns, self.user_ns) File “”, […]

Paginación de Cassandra: cómo usar get_slice para consultar una base de datos de Cassandra 1.2 desde Python usando la biblioteca cql

Tengo un cluster Cassandra 1.2 y lo estoy usando desde Python usando la biblioteca cql. Ahora necesito implementar alguna funcionalidad de paginación que parece bastante sencilla usando get_slice, pero no puedo encontrar ninguna documentación sobre cómo usar algo como esto en la biblioteca cql: get_slice(“key” : table_key, “column_parent” : {“column_family” : “MyColumnFamily”}, “predicate” : { […]

Error de decapado al ejecutar el comando COPY: CQLShell en Windows

Estamos ejecutando un comando de copia en CQLShell en Windows 7. Al principio, nos encontramos con un “COMANDO DE COPIA INCORRECTO”: COPY ourdata(data_time, data_ID, dataBlob) FROM ‘TestData.csv’ WITH HEADER = true; Más tarde comenzamos a recibir este error después de ejecutar el mismo comando: Error starting import process: Can’t pickle : it’s not found as […]