Tag: sqlalchemy

Создание отдельного подключения к базе данных для каждого работника сельдерея

Я продолжаю сталкиваться с проблемами mysql, в то время как рабочие выполняют задачи сразу после создания. Мы используем django 1.3, сельдерей 3.1.17, djorm-ext-pool 0.5 Мы начинаем процесс сельдерея с параллелизмом. До сих пор я наблюдал, что, когда начинается процесс работы, все они получают ту же связь mysql. Мы регистрируем идентификатор соединения db, как показано ниже. […]

UnicodeDecodeError Загрузка с помощью sqlalchemy

Я запрашиваю базу данных MySQL с sqlalchemy и получаю следующую ошибку: UnicodeDecodeError: 'utf8' codec can't decode bytes in position 498-499: unexpected end of data Столбец в таблице был определен как Unicode(500) поэтому эта ошибка подсказывает мне, что есть запись, которая была усечена, потому что она была длиннее 500 символов. Есть ли способ справиться с этой […]

sqlalchemy: остановка долгосрочного запроса

У меня есть, казалось бы, прямолинейная ситуация, но я не могу найти прямолинейное решение. Я использую sqlalchemy для запроса postgres. Если время ожидания клиента происходит, я хотел бы остановить / отменить длительные запросы postgres из другого потока. Поток имеет доступ к объекту Session или Connection. На данный момент я пробовал: session.bind.raw_connection().close() а также session.connection().close() а […]

Сервер MySQL ушел – Отключение обработки с помощью обработчика событий проверки не работает

Обновление 3/4: Я провел некоторое тестирование и доказал, что использование обработчика событий проверки для проверки отключений работает с Elixir. Начиная с того, что моя проблема связана с вызовом session.commit() из подпроцесса? Обновление: я просто опроверг себя, вызвав session.commit() в подпроцессе, обновленный пример ниже. Я использую модуль многопроцессорности для создания подпроцесса. Вот код, который показывает, как […]

SQLAlchemy повышает значение None, вызывает TypeError

Я использую декларативное расширение в SQLAlchemy, и я заметил странную ошибку, когда попытался сохранить экземпляр сопоставленного класса с неправильными данными (в частности, столбец с нулевым значением = False со значением None). Класс (упрощенный): class User(Base): __tablename__ = 'users' id = Column(Integer, primary_key=True, autoincrement=True) userid = Column(String(50), unique=True, nullable=False) Причинение ошибки (сеанс – сеанс SQLAlchemy): >>> […]

Отключение фиксации изменений объекта в SQLAlchemy

Я использую SQLAlchemy в проекте, который не является веб-приложением. Это серверное приложение, которое загружает несколько разных объектов из базы данных и изменяет их локально, но не хочет сохранять эти обновления в базе данных каждый раз, когда выдается фиксация. Ранее я работал с Django ORM для некоторых веб-проектов и нашел, что он лучше подходит для того, […]

Как смоделировать отношение «многие ко многим» в трех таблицах в SQLAlchemy (ORM)?

Я ржавый в SQL и совершенно новый для SQL Alchemy , но у меня есть предстоящий проект, который использует оба. Поэтому я решил написать кое-что, чтобы успокоиться. Страдая от похмелья, я решил написать что-то, чтобы следить за уровнем алкоголя. У меня есть events которых users участвуют и потребляют drinks . Это мои три основные таблицы […]

Как мне исправить этот sqlalchemy.exc.NoForeignKeysError?

Почему я получаю TraceBack sqlalchemy.exc.NoForeignKeysError sqlalchemy.exc.NoForeignKeysError: Could not determine join condition between parent/child tables on relationship County.Legislators – there are no foreign keys linking these tables. Ensure that referencing columns are associated with a ForeignKey or ForeignKeyConstraint, or specify a 'primaryjoin' expression. sqlalchemy.exc.NoForeignKeysError: Could not determine join condition between parent/child tables on relationship County.Legislators – […]

Значения столбцов python sqlalchemy

У меня есть 6 таблиц в моей базе данных SQLite, каждая таблица с 6 столбцами ( Date, user, NormalA, specialA, contact, remarks ) и 1000+ строк. Как я могу использовать sqlalchemy для сортировки столбца Date для поиска повторяющихся дат и удаления этой строки?

SqlAlchemy Left Присоединиться к счету

class Employee id name class Location id city class Work id employee_id location_id Todo: Left join with count (включая ноль) Желаемый результат location.city count NYC 10 SFO 5 CHI 0 Необработанный запрос: select location.id, count(work.id) as count from location left join work on location.id = work.location_id group by location.id SQLAlchemy: db_session.query(Location, func.count.work_id).label('count')). \ filter(location.id == […]

Python - лучший язык программирования в мире.