Обновление набора UDT с помощью CQLEngine

Я новичок в Cassandra, и я пытаюсь использовать CQLEngine ORM для обновления столбца набора, который содержит UDT, но я не могу, и в документации ничего не говорится о пользовательских типах.

Мой код;

class MyType(UserType):

    val = columns.Text()
    point = columns.Integer()
    key = columns.Text()

    def __init__(self, val, point, key, **values):
        super().__init__(**values)
        self.val = val
        self.point = point
        self.key = key


class MyModel(Model):

    myid = columns.UUID(primary_key=True)
    set_clm = columns.Set(columns.Integer)
    mytype = columns.Set(UserDefinedType(MyType))

    def __init__(self, set_clm, mytype, **values):
        super().__init__(**values)
        self.myid = uuid4()
        self.set_clm = set_clm
        self.mytype = mytype



s = MyModel.objects(myid="2b3adb7d-9e68-49fc-9aa0-26dbec607f9d").update(
    mytype__add=set(MyType(val="1", point=2, key="3"))
)

MyModel изначально содержит NULL в наборе, но когда я пытаюсь его обновить, я получаю следующую ошибку:

cassandra.InvalidRequest: Error from server: code=2200 [Invalid query] message="Invalid set literal for mytype: value 'point' is not of type frozen<mytype>"

'point' is not of type frozen<mytype> -> Эта часть случайным образом изменяется всякий раз, когда я перезапускаю код (в следующий раз, когда я запускаю, я получаю ту же ошибку для столбца «val» и т. д.).

Может ли кто-нибудь помочь мне, как я могу добавить набор UDT?


python cassandra cqlengine
person Robert    schedule 13.12.2016    source источник

Ответы (1)


arrow_upward
0
arrow_downward

ХОРОШО. Я решил это. Я записываю это для людей, которые найдут это в Google.

Это правильный способ добавления в набор: mytype__add={MyType(val="1", point=2, key="3")}

а также реализовать функцию __hash__ для MyType, например:

def __hash__():
    return hash(self.__repr__())

но с более умной функцией __hash__. Это просто пример. Надеюсь, это поможет кому-то еще.

person Robert    schedule 14.12.2016