Insertar a cassandra desde python usando cql

Estoy planeando insertar datos a continuación CF que tiene claves compuestas.

CREATE TABLE event_attend ( event_id int, event_type varchar, event_user_id int, PRIMARY KEY (event_id, event_type) #compound keys... ); 

Pero no puedo insertar datos en este CF desde python usando cql. (http://code.google.com/a/apache-extras.org/p/cassandra-dbapi2/)

 import cql connection = cql.connect(host, port, keyspace) cursor = connection.cursor() cursor.execute("INSERT INTO event_attend (event_id, event_type, event_user_id) VALUES (1, 'test', 2)", dict({}) ) 

Me sale el siguiente rastreo:

 Traceback (most recent call last): File "./v2_initial.py", line 153, in  db2cass.execute() File "./v2_initial.py", line 134, in execute cscursor.execute("insert into event_attend (event_id, event_type, event_user_id ) values (1, 'test', 2)", dict({})) File "/usr/local/pythonbrew/pythons/Python-2.7.2/lib/python2.7/site-packages/cql-1.4.0-py2.7.egg/cql/cursor.py", line 80, in execute response = self.get_response(prepared_q, cl) File "/usr/local/pythonbrew/pythons/Python-2.7.2/lib/python2.7/site-packages/cql-1.4.0-py2.7.egg/cql/thrifteries.py", line 80, in get_response return self.handle_cql_execution_errors(doquery, compressed_q, compress) File "/usr/local/pythonbrew/pythons/Python-2.7.2/lib/python2.7/site-packages/cql-1.4.0-py2.7.egg/cql/thrifteries.py", line 98, in handle_cql_execution_errors raise cql.ProgrammingError("Bad Request: %s" % ire.why) cql.apivalues.ProgrammingError: Bad Request: unable to make int from 'event_user_id' 

¿Qué estoy haciendo mal?

    Parece que está intentando seguir el ejemplo en: http://pypi.python.org/pypi/cql/1.4.0

     import cql con = cql.connect(host, port, keyspace) cursor = con.cursor() cursor.execute("CQL QUERY", dict(kw='Foo', kw2='Bar', kwn='etc...')) 

    Sin embargo, si solo necesita insertar una fila (como en su pregunta), simplemente suelte el parámetro dict () vacío.

    Además, dado que está utilizando claves compuestas, asegúrese de usar CQL3 http://www.datastax.com/dev/blog/whats-new-in-cql-3-0

     connection = cql.connect('localhost:9160', cql_version='3.0.0') 

    El siguiente código debería funcionar (solo adáptelo a localhost si es necesario):

     import cql con = cql.connect('172.24.24.24', 9160, keyspace, cql_version='3.0.0') print ("Connected!") cursor = con.cursor() CQLString = "INSERT INTO event_attend (event_id, event_type, event_user_id) VALUES (131, 'Party', 3156);" cursor.execute(CQLString) 

    Para Python 2.7, 3.3, 3.4, 3.5 y 3.6 para la instalación puede usar

      $ pip install cassandra-driver 

    Y en python:

      import cassandra 

    La documentación se puede encontrar en https://datastax.github.io/python-driver/getting_started.html#passing-parameters-to-cql-queries