1

Сервер (512 RAM) с: FLASK + SQLAlchemy (SQLite) -> uWSGI -> Nginx

SQLAlchemy возвращает разные данные при команде query.all (аналог SELECT).

Пример:

  • Добавляю пару записей в БД (проверяю - в БД они действиетльно присутствуют);
  • Загружаю страницу: все записи, кроме новых, возвращены. WTF?
  • Загружаю страницу: все записи возвращены (в том числе и новые). Отлично!
  • Загружаю страницу: все записи, кроме новых, возвращены. WTF?

Так продолжается, пока не перезагружу Flask приложение.

Буду шокирован, если кто-то поможет. Заранее благодарю!

Может быть, пригодится код:

DECLARATIVE_BASE = declarative_base()
engine = create_engine('sqlite:///database.db')
Session = sessionmaker(bind=engine)
session = Session()



class Order(DECLARATIVE_BASE):

    __tablename__ = 'orders'
    __table_args__ = (
        {'mysql_engine': 'InnoDB', 'sqlite_autoincrement': True,   'mysql_charset': 'utf8'}
    )

    id = Column(INTEGER, autoincrement=True, primary_key=True, nullable=False)  # pylint: disable=invalid-name
    name = Column(TEXT, nullable=False)
    address = Column(TEXT)
    phone = Column(TEXT, nullable=False)
    email = Column(TEXT)
    comment = Column(TEXT)
    totalPrice = Column(DECIMAL(asdecimal=False))
    orderItems = relationship(Orderitem)
    time = Column(TEXT, default=time.strftime("%H:%m %d.%m.%y"))

    def __repr__(self):
        return self.__str__()

    def __str__(self):
        return "<Order(%s)>" % self.__dict__


@app.route('/api/orders', methods=['GET'])
def getAllOrders():
    allOrders = session.query(Order).all()
    return json.dumps(allOrders, cls=new_alchemy_encoder(False, ['orderItems', 'product']), check_circular=False, ensure_ascii=False) #ensure_ascii=False -- for rigth out cyrlic;

2 ответа 2

1

Попробуй создать сессию как оф. документации flask написано или через flask-sqlalchemy.

from sqlalchemy import create_engine
from sqlalchemy.orm import scoped_session, sessionmaker
from sqlalchemy.ext.declarative import declarative_base

engine = create_engine('sqlite:////tmp/test.db', convert_unicode=True)
db_session = scoped_session(sessionmaker(autocommit=False,
                                         autoflush=False,
                                         bind=engine))
1

Спасибо большое!

Может кому пригодится: Дело действительно было в многопоточности и мультипроцессинге формируемым uWSGI. Объекты сессии в разных процессах не взаимодействовали друг с другом и отдавали старые закэшируемые данные.

Пока что я решил вопрос костылём: в конфигах uWSGI отключил мультипроцессинг и многопоточность - теперь никаких проблем нет, но сайт, конечно, не выдержит нагрузки.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.