-
guest说:
FastAPI引入日志系统,每次对数据库的操作都会打印sql日志
# utils/log.py """ 封装FastAPI的日志系统 """ import logging from fastapi.logger import logger logger.add( logger.file("log/app.log", format="{time} {level} {message}", rotation="1 day", retention="7 days"), level="INFO" ) # 日志等级 logging.basicConfig(level=logging.INFO) # 数据库sql日志 def sql_log(sql: str, *args, **kwargs): """ 打印sql语句日志 """ logger.info('SQL: ' + sql) logger.info('SQL ARGS: ' + str(args or kwargs))
# tests/conftest.py """ 测试时设置日志系统 """ import logging import pytest from utils.log import sql_log @pytest.fixture def set_log(): """ 设置日志系统 """ logging.basicConfig(level=logging.INFO) logging.getLogger('sqlalchemy.engine').setLevel(logging.INFO) logging.getLogger("sqlalchemy.pool").setLevel(logging.INFO) logging.getLogger("sqlalchemy.dialects.postgresql").setLevel(logging.INFO) from models.base import engine engine.echo = True engine.logger.setLevel(logging.INFO) engine.echo = False engine.logger.removeHandler(engine.logger.handlers[0]) engine.logger.addHandler(logging.StreamHandler()) engine.logger.addHandler(logging.FileHandler('log/sql.log')) engine.logger.info('SQL LOG ENABLED') engine.logger.info('='*80) engine.logger.info('') engine.log_pool_stats = True engine.logger.setLevel(logging.INFO) engine.logger.info('='*80) engine.logger.info('') engine.logger.info('SQL LOG DISABLED') engine.log_statement = sql_log
在测试文件中,重写sql_log,并在测试前后调用set_log来打印sql日志
# tests/test_user.py """ 用户模块单元测试 """ import json from fastapi.testclient import TestClient from app.main import app from models.user import User client = TestClient(app) def test_create_user(set_log): """ 测试创建用户 """ response = client.post("/users/", data=json.dumps({"username": "test_user", "password": "test_pass"}), headers={"Content-Type": "application/json"} ) assert response.status_code == 200 response_json = response.json() assert response_json["username"] == "test_user" assert response_json["password"] == "test_pass" user = User.get_by_username("test_user") assert user.username == "test_user"
运行测试时,在sql.log中可以看到数据库操作的日志:
2020-09-14 10:44:41,111 INFO SQL: SELECT users.id AS users_id, users.username AS users_username, users.password AS users_password FROM users WHERE users.username = %(username_1)s 2020-09-14 10:44:41,111 INFO SQL ARGS: {'username_1': 'test_user'} 2020-09-14 10:44:41,111 INFO SQL: INSERT INTO users (username, password) VALUES (%(username)s, %(password)s) RETURNING users.id 2020-09-14 10:44:41,111 INFO SQL ARGS: {'password': 'test_pass', 'username': 'test_user'}
-
guest说:
FastAPI日志系统,打印sqlalchemy执行过程中的每次sql语句
使用
fastapi_sqlalchemy
提供的SQLAlchemyMiddleware
类,可以在每次sql语句执行的时候,自动记录到FastAPI的日志系统中:from fastapi_sqlalchemy import SQLAlchemyMiddleware # 初始化SQLAlchemyMiddleware sqlalchemy_middleware = SQLAlchemyMiddleware() # 将SQLAlchemyMiddleware绑定到app上 app.add_middleware(sqlalchemy_middleware)
每次sql执行完成后,就会在FastAPI日志系统中记录下sql语句:
INFO: SELECT users.id AS users_id FROM users ORDER BY users.id ASC
-
guest说:
FastAPI日志系统结合sqlalchemy使用
FastAPI是一个支持快速开发和部署的Web框架,可以用来构建RESTful API。它拥有强大的日志系统,可以帮助开发者记录和监控应用程序的运行情况。
要在FastAPI中使用SQLAlchemy,您需要将SQLAlchemy与FastAPI的日志系统结合使用。SQLAlchemy提供一个强大的ORM,它可以帮助您更轻松地管理数据库中的数据。
要使SQLAlchemy与FastAPI的日志系统结合起来,您需要创建一个FastAPI的logger,它将负责记录日志信息。您可以在FastAPI的配置文件中设置logger,以指定日志记录的格式和级别。
接下来,您需要将SQLAlchemy附加到FastAPI的logger中。可以通过设置SQLAlchemy的日志级别来实现这一点。SQLAlchemy支持多个日志级别,包括debug,info,warning,error和critical。您可以设置SQLAlchemy的日志级别,以便它只记录您感兴趣的日志信息。
最后,您需要将SQLAlchemy的日志处理器附加到FastAPI的logger中。这样,SQLAlchemy日志信息就会被记录到FastAPI的日志中,从而使您可以更轻松地监控应用程序的运行情况。
通过将SQLAlchemy与FastAPI的日志系统结合起来,您可以更轻松地管理数据库中的数据,并且可以更好地监控应用程序的运行情况。
-
guest说:
FastAPI配置日志
- 安装starlette日志插件:
pip install starlette-logging
- 在
main.py
中导入插件:
from starlette_logging import LoggingMiddleware
- 配置日志:
import logging logging.basicConfig(level=logging.DEBUG, format='%(asctime)s %(levelname)s %(name)s:%(message)s') app.add_middleware(LoggingMiddleware)
- 将以上配置应用到FastAPI应用中:
app = FastAPI(title="My App", debug=True) # 配置日志 import logging logging.basicConfig(level=logging.DEBUG, format='%(asctime)s %(levelname)s %(name)s:%(message)s') app.add_middleware(LoggingMiddleware) # 其他FastAPI配置 @app.get("/") def read_root(): return {"Hello": "World"}
- 运行应用:
uvicorn main:app
- 运行结果:
INFO: Started server process [23866] INFO: Waiting for application startup. INFO: Application startup complete. INFO: Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)
-
guest说:
SQLAlchemyMiddleware详细使用方法,绑定main.py
SQLAlchemyMiddleware是一个Flask中间件,它可以帮助我们在Flask应用程序中使用SQLAlchemy。它的核心功能是在每次请求期间管理SQLAlchemy会话。
要使用SQLAlchemyMiddleware,首先我们需要安装它:
$ pip install Flask-SQLAlchemy-Session
接下来,我们可以在main.py文件中绑定中间件:
from flask import Flask
from flask_sqlalchemy_session import SQLAlchemySessionMiddlewareapp = Flask(name)
Bind the middleware
app.wsgi_app = SQLAlchemySessionMiddleware(app.wsgi_app)
然后,我们可以使用SQLAlchemyMiddleware的方法来完成一些任务,比如添加一个新的会话:
Add a new session
from sqlalchemy_session import Session
session = Session()
session.add(app)Close the session when done
@app.teardown_appcontext
def close_session(exception=None):
session.remove()这样,我们就可以在Flask应用程序中使用SQLAlchemy了。
-
guest说:
DBSessionMiddleware.init() missing 1 required positional argument: 'app'
DBSessionMiddleware is a class for which you must supply an app argument when initializing it.
The app argument should be a web application object, such as a Flask application. This class is used to manage database sessions in a web application. -
guest说:
FastAPI引入日志系统,每次对数据库的操作都会打印sql日志并且列出目录结构
首先,需要在FastAPI中安装SQLAlchemy,SQLAlchemy是一种数据库抽象层,可以让你在不同数据库之间进行数据库操作:
pip install SQLAlchemy
然后,需要在FastAPI中引入logging模块,并设置日志级别:
import logging logging.basicConfig(level=logging.INFO)
接着,需要创建一个logger对象,并为其添加一个文件处理器,以便将日志记录到文件中:
logger = logging.getLogger('sqlalchemy.engine') fh = logging.FileHandler('sql.log') logger.addHandler(fh)
最后,需要设置日志级别,以便记录SQL查询:
logger.setLevel(logging.INFO)
这样,每次对数据库的操作都会在sql.log文件中记录下来,并且可以查看每一条SQL查询的目录结构。
-
@ChatGPT WeChatBOT会对微信有什么影响吗?