class Comment(db.Model):
  id = db.Column(db.Integer, primary_key=True)
  post_id = db.Column(db.Integer, db.ForeignKey("post.id"))
  author_id = db.Column(db.Integer, db.ForeignKey("user.id"))
  floor = db.Column(db.Integer)
  content = db.Column(db.Text())
  html = db.Column(db.Text())
  create_at = db.Column(db.DateTime(), default=datetime.utcnow)
  parent_id = db.Column(db.Integer, db.ForeignKey("comment.id"))
  replies = db.relationship(
    "Comment", backref=db.backref("parent", remote_side=[id]), lazy="dynamic"
  )

  __table_args__ = (db.UniqueConstraint("post_id", "floor", name="_post_floor"),)

<link rel="stylesheet" href="https://cdn.jsdelivr.net/simplemde/latest/simplemde.min.css" rel="external nofollow" >
<script src="/UploadFiles/2021-04-08/simplemde.min.js">

完事！后续可能会考虑加上emoji选择器。markdown保存，后端渲染html，前端取出展示。最后结果非常漂亮令我满意，大家可以在本篇文章下面看到效果。
评论管理
对应的，在管理员页面也加上一个评论管理页面，以及开启内置评论的开关。因为最初设计的是评论一经发出，只能删除，不能修改，所以这种页面对我这样的CRUD程序员来说不在话下。
现在就到了激动人心的时刻了，把Disqus的评论数据迁移过来！我到Disqus页面上去看，发现Disqus支持导出评论数据为特定的结构，是一个xml，只要是结构化的数据，那就问题不大了。主要分为两个部分，前半部分是thread的列表，表示有哪些文章开启了Disqus的评论，包含文章的url等信息（取决于你如何开启的Disqus），后半部分是评论列表，每条评论有评论内容、作者信息、回复的上级评论ID，还好数据模型设计得好，这些都在射程范围内。于是写了一个函数解析，导入这些数据，注意有些已删除的或者垃圾评论直接过滤掉即可，函数放在这里了。

上传文件，导入，成功，Disqus的评论就完美迁移过来了！
评论通知
评论通知需要拿到用户的联系方式，所以表单中电子邮件是必填的，接入第三方登录时，我也要考虑哪些服务是可以获得联系方式的，目前决定是用Github，Google两种方式，至于新浪微博，虽然国人常用，但好像没有谁会在微博上留联系方式，所以排除，微信倒是很好，但微信的第三方登录好像很麻烦的样子，暂不考虑。所以最后就是邮件通知。那就简单了，用Flask的扩展Flask-Mail全都搞定，但在使用中我遇到两个坑：
如果在后台任务中做发送邮件的操作，注意获取g对象需要应用上下文，获取请求信息需要请求上下文，而光用Flask提供的copy_current_request_context只复制请求上下文，而会创建新的应用上下文，我写了两个函数，一个是添加应用和请求上下文到一个函数，另一个是将函数转换成后台任务:


def with_app_context(f):
  ctx = _app_ctx_stack.top
  req_ctx = _request_ctx_stack.top.copy()

  def wrapper(*args, **kwargs):
    with ctx:
      with req_ctx:
        return f(*args, **kwargs)
  return update_wrapper(wrapper, f)


def background_task(f):
  def wrapper(*args, **kwargs):
    future = gevent.spawn(with_app_context(f), *args, **kwargs)

    def callback(result):
      exc = result.exception
      current_app.log_exception((type(exc), exc, exc.__traceback__))

    future.link_exception(with_app_context(callback))
    return future

  return update_wrapper(wrapper, f)


这里后台任务用了gevent，如果用线程方式，则改成


from concurrent.futures import ThreadPoolExecutor

def background_task(f):
  def wrapper(*args, **kwargs):
    with ThreadPoolExecutor() as pool:
      future = pool.submit(with_app_context(f), *args, **kwargs)

    def callback(result):
      exc = result.exception()
      if exc is not None:
        current_app.log_exception((type(exc), exc, exc.__traceback__))

    future.add_done_callback(with_app_context(callback))
    return future

  return update_wrapper(wrapper, f)


腾讯云的主机默认禁掉了25端口，害我找了半天原因，只要自己在控制台解禁一下即可立刻生效。
参考链接
源码仓库: https://github.com/frostming/Flog

Implementing User Comments with SQLAlchemy - miguelgrinberg.com
以上就是如何使用 Flask 做一个评论系统的详细内容，更多关于flask 做评论系统的资料请关注其它相关文章！