[免费课] FastAPI 框架精讲

Author: liaogx

.gitignore

@@ -0,0 +1,178 @@
+### Python template
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+.hypothesis/
+
+# Translations
+*.mo
+*.pot
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+# pyenv
+.python-version
+
+# celery beat schedule file
+celerybeat-schedule
+
+# Environments
+.venv
+venv/
+ENV/
+.envs/*
+env.bak/
+venv.bak/
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# godie
+.godie_cache/
+
+# Logs
+/logs/
+*.log
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# Typescript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of "npm pack"
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+
+### Linux template
+*~
+
+# temporary files which can be created if a process still has a handle open of a deleted file
+.fuse_hidden*
+
+# KDE directory preferences
+.directory
+
+# Linux trash folder which might appear on any partition or disk
+.Trash-*
+
+# .nfs files are created when an open file is removed but is still being accessed
+.nfs*
+
+
+### Project template
+.pytest_cache/
+.ipython/
+
+# Django stuff:
+godie/static/
+godie/staticfiles/
+godie/media/
+.static_storage/
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# SageMath parsed files
+*.sage.py
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# pycharm
+/.idea/

README.md

@@ -0,0 +1,5 @@
+#!/usr/bin/python3
+# -*- coding:utf-8 -*-
+# __author__ = '__Jack__'
+
+from .main import application

coronavirus/__init__.py

@@ -0,0 +1,75 @@
+#!/usr/bin/python3
+# -*- coding:utf-8 -*-
+# __author__ = '__Jack__'
+
+from sqlalchemy import create_engine, Column, String, Integer, BigInteger, Date, DateTime, ForeignKey, func
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy.orm import sessionmaker, relationship
+
+SQLALCHEMY_DATABASE_URL = 'sqlite:///./coronavirus.db'
+# SQLALCHEMY_DATABASE_URL = "postgresql://username:password@host:port/database_name"  # MySQL或PostgreSQL的连接方法
+
+engine = create_engine(
+    # echo=True表示引擎将用repr()函数记录所有语句及其参数列表到日志
+    # 由于SQLAlchemy是多线程，指定check_same_thread=False来让建立的对象任意线程都可使用
+    SQLALCHEMY_DATABASE_URL, encoding='utf-8', echo=True, connect_args={'check_same_thread': False}
+)
+
+# 在SQLAlchemy中，CRUD都是通过会话(session)进行的，所以我们必须要先创建会话
+# flush()是指发送数据库语句到数据库，但数据库不一定执行写入磁盘；commit()是指提交事务，将变更保存到数据库文件
+SessionLocal = sessionmaker(bind=engine, autoflush=False, autocommit=False, expire_on_commit=True)
+
+# 创建基本映射类
+Base = declarative_base(bind=engine, name='Base')
+
+
+class City(Base):
+    __tablename__ = 'city'
+
+    id = Column(Integer, primary_key=True, index=True, autoincrement=True)
+    province = Column(String(100), unique=True, nullable=False, comment='省/直辖市')
+    country = Column(String(100), nullable=False, comment='国家')
+    country_code = Column(String(100), nullable=False, comment='国家代码')
+    country_population = Column(BigInteger, nullable=False, comment='国家人口')
+    data = relationship('Data', backref='city')  # 'Data'是关联的类名；backref来指定反向访问的属性名称
+
+    created_at = Column(DateTime, server_default=func.now(), comment='创建时间')
+    updated_at = Column(DateTime, server_default=func.now(), onupdate=func.now(), comment='更新时间')
+
+    __mapper_args__ = {"order_by": country_code}  # 默认是正序，倒序加上.desc()方法
+
+    def __repr__(self):
+        return f'{self.country}_{self.province}'
+
+
+class Data(Base):
+    __tablename__ = 'data'
+
+    id = Column(Integer, primary_key=True, index=True, autoincrement=True)
+    city_id = Column(Integer, ForeignKey('city.id'), ondelete='CASCADE', comment='所属省/直辖市')  # ForeignKey里的字符串格式不是类名.属性名，而是表名.字段名
+    date = Column(Date, nullable=False, comment='数据日期')
+    confirmed = Column(BigInteger, default=0, nullable=False, comment='确诊数量')
+    deaths = Column(BigInteger, default=0, nullable=False, comment='死亡数量')
+    recovered = Column(BigInteger, default=0, nullable=False, comment='痊愈数量')
+    city = relationship('City', backref='data')  # 'City'是关联的类名；backref来指定反向访问的属性名称
+
+    created_at = Column(DateTime, server_default=func.now(), comment='创建时间')
+    updated_at = Column(DateTime, server_default=func.now(), onupdate=func.now(), comment='更新时间')
+
+    __mapper_args__ = {"order_by": confirmed}
+
+    def __repr__(self):
+        return f'{repr(self.date)}：确诊{self.confirmed}例'
+
+
+""" 附上三个SQLAlchemy教程
+
+SQLAlchemy的基本操作大全 
+    http://www.taodudu.cc/news/show-175725.html
+
+Python3+SQLAlchemy+Sqlite3实现ORM教程 
+    https://www.cnblogs.com/jiangxiaobo/p/12350561.html
+
+SQLAlchemy基础知识 Autoflush和Autocommit
+    https://zhuanlan.zhihu.com/p/48994990
+"""

coronavirus/database.py

@@ -0,0 +1,116 @@
+#!/usr/bin/python3
+# -*- coding:utf-8 -*-
+# __author__ = '__Jack__'
+
+from fastapi import Request, Depends, BackgroundTasks, APIRouter
+from pydantic import BaseModel
+from sqlalchemy.orm import Session
+
+
+# from coronavirus.database import engine, SessionLocal, Base
+
+
+from fastapi.staticfiles import StaticFiles
+from fastapi.templating import Jinja2Templates
+
+
+application = APIRouter()
+
+
+application.mount('/static', StaticFiles(directory='./coronavirus/static'), name='static')
+templates = Jinja2Templates(directory='./coronavirus/templates')
+
+
+# Base.metadata.create_all(bind=engine)
+
+
+@application.get("/")
+async def index(request: Request):
+    return templates.TemplateResponse("index.html", {"request": request, "title": "This is title"})  # {"request": request}是必须的
+
+
+@application.get("/coronavirus")
+async def coronavirus():
+    """This is a simple tutorial"""
+    return {"message": {"This is another route"}}
+
+
+# class StockRequest(BaseModel):
+#     symbol: str
+#
+#
+# def get_db():
+#     try:
+#         db = SessionLocal()
+#         yield db
+#     finally:
+#         db.close()
+#
+#
+# @application.get("/")
+# def home(request: Request, forward_pe=None, dividend_yield=None, ma50=None, ma200=None, db: Session = Depends(get_db)):
+#     """
+#     displays the stock screener dashboard / homepage
+#     :return:
+#     """
+#     stocks = db.query(Stock)
+#
+#     if forward_pe:
+#         stocks = stocks.filter(Stock.forward_pe < forward_pe)
+#
+#     if dividend_yield:
+#         stocks = stocks.filter(Stock.dividend_yield > dividend_yield)
+#
+#     if ma50:
+#         stocks = stocks.filter(Stock.price > Stock.ma50)
+#
+#     if ma200:
+#         stocks = stocks.filter(Stock.price > Stock.ma200)
+#
+#     return templates.TemplateResponse("home.html", {
+#         "request": request,
+#         "stocks": stocks
+#     })
+#
+#
+# def fetch_stock_data(id_: int):
+#     """
+#     fetch data from yahoo finance
+#     :param id_:
+#     :return:
+#     """
+#     db = SessionLocal()
+#     stock = db.query(Stock).filter(Stock.id == id_).first()
+#
+#     yahoo_data = yf.Ticker(stock.symbol)
+#
+#     stock.ma50 = yahoo_data.info["fiftyDayAverage"]
+#     stock.ma200 = yahoo_data.info["twoHundredDayAverage"]
+#     stock.price = yahoo_data.info["previousClose"]
+#     stock.forward_pe = yahoo_data.info["forwardPE"]
+#     stock.forward_eps = yahoo_data.info["forwardEps"]
+#     if yahoo_data.info["dividendYield"]:
+#         stock.dividend_yield = yahoo_data.info["dividendYield"] * 100
+#
+#     db.add(stock)
+#     db.commit()
+#
+#
+# @application.post("/stock")
+# async def create_stock(stock_request: StockRequest, background_tasks: BackgroundTasks, db: Session = Depends(get_db)):
+#     """
+#     created a stock and stores it in the database
+#     :return:
+#     """
+#     stock = Stock()
+#     stock.symbol = stock_request.symbol
+#
+#     db.add(stock)
+#     db.commit()
+#
+#     background_tasks.add_task(fetch_stock_data, stock.id)
+#
+#     return {
+#         "code": "success",
+#         "message": "stock created"
+#     }