在Crate上查询时遇到“卡住”

Question

我运行了循环，并在每个循环中密集查询了大量数据。我的数据库是使用Crate构建的。有时，循环会暂停，因为Crate没有响应我的查询结果。(这种情况并不总是发生)伪代码如下所示

from crate import client

class data_access(object):
    def __init__(self, IP):
        conn = client.connect(IP)
        self.cursor = conn.cursor()

    def get_report(self, event_id):
        self.cursor.execute('''
            select schema.events."Info", schema.events."Time"
            from schema.events
            where schema.events."Id"='%s' ''' % event_id)

        event = []
        for row in self.cursor:
           event.append((row[0], row[1]))

        return event


dal = data_access("server IP")
all_events = []
for event_id in event_ids:
    events = dal.get_report(event_id)
    if len(events) >0: all_event += events

event_ids的长度可能有数百万，并且在每个循环中查询都是密集的。使用Crate的数据库专家有没有遇到过这个问题？如果是，您是如何解决这个问题的？重启数据库似乎不起作用。非常感谢您的解决方案！

Answer 1

我无法重现这一点，但我怀疑这可能是因为您每次都在循环内创建连接。我不会重新创建连接数百万次，而是在循环外部重写一次来创建连接，然后将其传递到get_report中，如下所示：

from crate import client

def get_report(event_id, conn):
    cursor = conn.cursor()
    cursor.execute('''
       select schema.events."Info", schema.events."Time"
       from schema.events
       where schema.events."Id"='%s' ''' % event_id)

    event = []
    for row in cursor:
       event.append((row[0], row[1]))

    return event


all_events = []
conn = client.connect("server IP")
for event_id in event_ids:
    events = get_report(event_id, conn)
    if len(events) >0: all_event += events