Я пытаюсь выполнить обновление с помощью flask-sqlalchemy, но когда он попадает в скрипт обновления, он ничего не возвращает. похоже скрипт завис или ничего не делает.
Я попытался обернуть попытку поймать код, который не завершается, но ошибок нет.
Я дал ему 10 минут, чтобы выполнить оператор обновления, который обновляет только 1 запись, но по какой-то причине он ничего не делает.
Когда я отменяю сценарий, он выдает ошибку Сбой канала связи (0) (SQLEndTran), но я не думаю, что это основная причина ошибки, потому что в том же сценарии у меня есть другие сценарии sql, которые работают нормально, поэтому соединение для БД это хорошо
что делает мой скрипт, так это получает список имен файлов, которые мне нужно обработать (у меня нет проблем с этим). затем, используя полученный список имен файлов, я загляну в каталог, чтобы проверить, существует ли файл. если он не существует, я обновлю базу данных, чтобы пометить файл как не найденный. вот где я получаю проблему, он не выполняет обновление и не предоставляет какое-либо сообщение об ошибке.
Я даже пытался создать новый движок только для скрипта обновления, но все равно получаю такое же поведение.
Я также попытался сначала распечатать сценарий sql в python перед выполнением. Я запустил напечатанную команду sql в своем браузере sql, и она работала нормально.
Код очень простой, я не совсем уверен, почему у него возникла проблема.
#!/usr/bin/env python3
from flask_sqlalchemy import sqlalchemy
import glob
files_directory = "/files_dir/"
sql_string = """
select *
from table
where status is null
"""
# ommited conn_string
engine1 = sqlalchemy.create_engine(conn_string)
result = engine1.execute(sql_string)
for r in result:
engine2 = sqlalchemy.create_engine(conn_string)
filename = r[11]
match = glob.glob(f"{files_directory}/**/{filename}.wav")
if not match:
print('no match')
script = "update table set status = 'not_found' where filename = '" + filename + "' "
engine2.execute(script)
engine2.dispose()
continue
engine1.dispose()
да это то, что я делал раньше. в моем коде объявлен только 1 движок, а функция dispose вызывается только в конце. Я просто добавил их, чтобы проверить, получится ли по-другому, но это то же самое.
похоже, что если я попытаюсь просмотреть 26k записей, скрипт не сработает. а вот когда попробую делать партиями по 2к записей за прогон, то скрипт сработает. поэтому моя строка sql станет (добавлено 2000 лучших в запросе)
sql_string = """
select top 2000 *
from table
where status is null
"""
это вручную, да, но это работает для меня, так как мне просто нужно запустить этот скрипт один раз. (я имею в виду 13 раз)
Я могу прокрутить до 4к записей макс. если я попытаюсь перебрать 5k записей выше, скрипт почему-то не сработает.
Если
engine2
не является отдельной базой данных, вам не нужно создавать новуюengine
на каждой итерации вашего цикла. Кроме того, если вы не вводите свое состояниеif not match
, вы не избавляетесь отengine2
.