Повторяющиеся строки в cassandra

#python #jenkins #cassandra #celery

#python #дженкинс #кассандра #сельдерей

Вопрос:

Я получил метод, отправляющий данные в таблицу Cassandra. Каким-то образом я могу (иногда) добавлять повторяющиеся строки, чего не должно быть. Ниже приведен метод, который я написал для этого. Я проверяю, существует ли это имя уже, и если да, то данные не должны публиковаться.

Что-нибудь очевидное, чего мне не хватает?

     print(args)
    jm = Jenkins()
    #print(json.dumps(args, sort_keys=True, indent=4))

    for i in args:
        jm.name = i['fullDisplayName']
        jm.result = i['result']
        jm.jobnumber = str(i['id'])
        jm.executor = i['executor']
        jm.duration = str(i['duration'])
        jm.time_stamp = str(i['timestamp'])
        jm.url = i['url']
        jm.id = str(uuid.uuid4())

        check_if_table_is_empty = len(Jenkins.objects.all())
        if (check_if_table_is_empty is 0):
                Jenkins.create(name=jm.name, result=jm.result, jobnumber=jm.jobnumber, executor=jm.executor,
                                      duration=jm.duration, time_stamp=jm.time_stamp, url=jm.url, id=jm.id)
                return jm.id
        else:
                for data in Jenkins.objects.all():
                        if (data['name'] == jm.name):
                                return data['id']
                        else:
                                jm.save()
                                return jm.id



 id                                   | duration | executor | jobnumber | name                       | result  | time_stamp    | url
-------------------------------------- ---------- ---------- ----------- ---------------------------- --------- --------------- ---------------------------------------------------------
 5dd7ba97-fd93-4a54-bce6-002502f0e96b |     7912 |     null |        10 | alten-training-develop #10 | ABORTED | 1530273379763 | **********************
 7d8209f3-d5fd-4fa3-9c6c-1f5030928407 |    30222 |     null |         6 |        adbridge-develop #6 | FAILURE | 1529907888157 |        **********************
 a43f00df-a6cf-45d9-9190-fe06cfa28327 |    30222 |     null |         6 |        adbridge-develop #6 | FAILURE | 1529907888157 |        **********************






 servicename            | address              | matchtype  | samplingtype | servicetype
------------------------ ---------------------- ------------ -------------- -------------
 alten-training-develop | *****.*****.se:8081 | ['RegEx1'] |         HTTP |     Jenkins
       adbridge-develop | *****.****.se:8081 | ['RegEx1'] |         HTTP |     Jenkins

 

Комментарии:

1. Чтобы проверить, что имя существует, вам нужно указать его в качестве ключа раздела …, но в вашем выводе id это ключ раздела… Можете ли вы добавить схему для этой таблицы?

2. класс Дженкинс (модель): имя = столбцы. Text() id = столбцы. Текст (primary_key=True, по умолчанию=uuid.uuid4) номер задания = столбцы. Текст() url = столбцы. Текст () длительность = столбцы. Исполнитель текста() = столбцы. Результат Text() = столбцы. Text() time_stamp = столбцы. Текст()

3. Разрешил его с помощью ключа раздела в столбце name