У меня есть приложение, которое обновляет записи в динамо-БД, которые являются не чем иным, как обновленной меткой времени в формате UTC текущего времени. У меня есть задача, в которой я пытаюсь обновить все 94000 записей, используя новую временную метку UTC. Моя текущая конфигурация динамо-БД рассчитана на 80 единиц чтения и записи. После завершения этой задачи я проверил, и он обновил записи до 50%, но не все. Все операции обновления выполняются на существующих индексированных с емкостью 80 единиц чтения / права.
Что делать, если я превышаю емкость записи? будет ли он по-прежнему обновлять записи с некоторой задержкой? или он просто сдастся на полпути?
result = cls.db_table.scan(req_id__eq=str(req.id))
for req in result:
req['timestamp'] = time() * 1000
if not req.partial_save():
LOGGER.error('Unable to update req {}'.format(req.items()))
Что делать, если я превышаю емкость записи?
При превышении единиц емкости записи DynamoDB выдаст исключение ProvisionedThroughputExceededException.
будет ли он по-прежнему обновлять записи с некоторой задержкой? или он просто сдастся на полпути?
Это вызовет исключение при превышении единиц емкости записи. Однако DynamoDB может обрабатывать некоторые пакетные записи, но не в течение длительного времени.
@ROHIT Какой ответ вы получаете?
lead.partial_save () всегда возвращает истину, поэтому со стороны моего кода я не могу сказать, обновлен ли он / нет
@ROHIT, не могли бы вы опубликовать свой фрагмент кода, который делает это?
Обновил мой вопрос отрывком.
Я использую библиотеку boto на python, я вообще не получаю ProvisionedThroughputExceededException, но я получил сигнал тревоги Dynamodb в консоли AWS, в котором говорится, что емкость чтения / записи превышена. для лидерства в результате: lead ['timestamp'] = time () * 1000, если не lead.partial_save (): LOGGER.error ('Невозможно обновить свинец {}'. format (lead.items ())) я не получить любой журнал тоже.