Запрос к Cassandra Object Mapper

Question

Я пытаюсь выяснить, как заменить эти два запроса Object Mapper, так как это требование, но я не могу решить это.

Кто-нибудь, кто может указать мне правильное направление?

Запрос вставляется ниже

Я пытался с фильтром (), но он не будет работать

rows = session.execute('SELECT gocd, serverdependencies, jenkins, nodes FROM application WHERE name=%s',{apps})

rows = session.execute('SELECT toJson(address) FROM service WHERE servicename=%s', [service])
    for row in rows:
        result.append(row)

Answer 1

Просто следуйте документации . Я только что проверил с последней версией драйвера, и filter отлично работает:

from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
from cassandra.cqlengine import connection

class Application(Model):
     name = columns.Text(primary_key=True)
     gocd = columns.List(value_type=columns.Text)
     jenkins = columns.List(value_type=columns.Text)
     serverdependencies = columns.List(value_type=columns.Text)

connection.setup(['127.0.0.1'], "test", protocol_version=3)
q = Application.objects.filter(name='test')
q[:]

и выводит следующее:

[Application(name='test', gocd=[u'test'], jenkins=[], serverdependencies=[])]

для следующих данных:

cqlsh:test> SELECT * from application ;

 name | gocd     | jenkins | nodes | serverdependencies
------+----------+---------+-------+--------------------
 test | ['test'] |    null |  null |               null