Как использовать курсоры в Google App Engine для пакетного извлечения записей из базы данных БД?

Я пытаюсь получить данные из базы данных db партиями и скопировать их в базу данных ndb, используя курсор. Мой код делает это успешно для первой партии, но не получает никаких дальнейших записей. Я не нашел много информации о курсорах, пожалуйста, помогите мне здесь.

Вот мой фрагмент кода: def post(self):

    a = 0   
    chunk_size = 2
    next_cursor = self.request.get("cursor")
    query = db.GqlQuery("select * from BooksPost")

    while a == 0:
        if next_cursor:
            query.with_cursor(start_cursor = next_cursor)
        else:
            a = 1
       
        results = query.fetch(chunk_size)

        for result in results: 
            nbook1 = result.bookname
            nauthor1 = result.authorname
            nbook1 = nBooksPost(nbookname = nbook1, nauthorname = nauthor1)
            nbook1.put()
            next_cursor = self.request.get("cursor")

В принципе, как мне установить следующий курсор для повторения?


database google-app-engine gql cursors
person Nidhi Gupta    schedule 26.08.2020    source источник
comment
какой код пробовал? Какую БД вы используете, в частности?   -  person GAEfan    schedule 26.08.2020
comment
Вот мой фрагмент кода:   -  person Nidhi Gupta    schedule 27.08.2020
comment
Привет! Опубликовал фрагмент кода, в котором мой запрос извлекает 2 записи за раз из базы данных db и записывает в базу данных ndb. Как это сделать для всех записей?   -  person Nidhi Gupta    schedule 27.08.2020

Ответы (1)


arrow_upward
1
arrow_downward

деф пост(я):

    chunk_size = 10
    has_more_results = True
    query = db.GqlQuery("select * from Post")  
    cursor = self.request.get('cursor', None)
    #cursor = query.cursor()
    if cursor:
        query.with_cursor(cursor)
    
    while has_more_results == True:
        
        results = query.fetch(chunk_size)
        new_cursor = query.cursor()
        print("count: %d, results %d" % (query.count(), len(results)))
                
        if query.count(1) == 1:
            has_more_results = True
        else:
            has_more_results = False    
                  
        for result in results: 
            #do this
            
        query.with_cursor(new_cursor)
person Nidhi Gupta    schedule 27.08.2020