Cassandra 更新失败

Question

已解决 我正在3个节点上测试更新，其中一个节点上的时间落后1秒，因此当更新一行时，写入时间始终落后于时间戳，cassandra不会更新行。我同步了所有节点的时间，问题就解决了。

编辑: 我仔细检查了结果，所有插入都成功，部分更新失败。没有错误/异常消息

我有一个 cassandra 集群(Cassandra 2.0.13)，其中包含 5 个节点。使用 python(2.6.6) cassandra driver(2.6.0c2) 将数据插入数据库。我的服务器系统是Centos6.X

以下代码是我如何连接到 cassandra 并获取 session 。我最多提供2个节点ip地址，并选择keyspace。

def get_cassandra_session():
    """creates cluster and gets the session base on key space"""
    # be aware that session cannot be shared between threads/processes
    # or it will raise OperationTimedOut Exception
    if CLUSTER_HOST2:
        cluster = cassandra.cluster.Cluster([CLUSTER_HOST1, CLUSTER_HOST2])
    else:
        # if only one address is available, we have to use older protocol version
        cluster = cassandra.cluster.Cluster([CLUSTER_HOST1], protocol_version=1)

    session = cluster.connect(KEY_SPACE)
    return session 

对于每一行，我有 17 列，如果数据库中不存在该键，我将使用 session 插入键和其余列的默认值，然后更新特定列的值。

def insert_initial_row(session, key):
    session.execute(INITIAL_INSERTION_STATEMENT, tuple(INITIAL_COLUMNS_VALUES))


def update_columnX(session, key, column):
    session.execute("INSERT INTO " + TABLE + "(" + KEY + "," + COLUMN_X + ") VALUES(%s, %s)", (key, column))

def has_found(session, key):
    """checks key is in database or not"""
    query = "SELECT " + "*" + " FROM " + KEY_SPACE + "." + TABLE \
            + " WHERE " + KEY + " = " + "'" + key + "'"
    # returns a list
    row = session.execute(query)
    return True if row else False

以下是我调用它们的方式:

for a_key in keys_set:
    """keys_set contains 100 no duplicate keys"""
    if has_found(session, a_key):
        update_columnX(session, a_key, "column x value")
    else:
        """the key is not in db, initialize it with all default values, then update column x"""
        insert_initial_row(session,  a_key)
        if has_found(sessin, a_key):
            update_columnX(session,  a_key, "column x value")
        else:
            logger.error("not initialized correctly...")

我试图插入100行并更新每行的columnX，但只能更新这100行中的一部分，其余行的columnX是默认值。insert_initial_row已被调用并初始化为default所有 100 行的值，但 update_columnX 没有。如果我将一致性级别更改为 Quorum，则完全没有帮助。 “未正确初始化...”从未打印出来，我在 update_columnX 中添加了 print 行，并且该行打印了 100 次，所以它被调用 100 次，但并非全部都更新。

有什么想法吗？请帮忙。

谢谢

Answer 1

如果您的session.execute写入不成功(未满足所需的一致性级别)，则驱动程序将引发以下异常之一:

1. Unavailable - 没有足够的实时副本来满足请求的一致性级别，因此协调器节点立即使请求失败，而不将其转发到任何副本。
2. Timeout - 副本在 cassandra 超时之前未响应协调器。
3. Write timeout - 副本在写入超时之前未响应协调器。在 cassandra.yaml 中配置。读取也有类似的超时，在yaml中分别配置读取和写入超时。
4. Operation timeout - 操作花费的时间超过指定的客户端超时时间。在您的应用程序代码中进行配置。

您可以尝试tracing您的查询并找出每次写入到底发生了什么。这将向您显示参与操作的协调器和副本节点以及请求在每个节点上花费的时间。