在启动时创建对象并跨请求共享

Question

我想将我的 Django 应用程序用作基于会话的在线服务的中继，并在所有用户之间共享此会话。为此，我配置了一个python-requests Session 对象。

我想在 Django 启动时初始化这个 Session 并让它永远活着。我的想法是通过允许特定请求的视图访问会话对象，让对我的 Django 应用程序的所有请求共享会话对象。

在 Flask 中进行设置（用于实验目的）相当简单：

from flask import Flask, render_template, request, session
from requests import Session
app = Flask(__name__)

session = Session()
session.post()        # Setup Session by logging in

@app.route("/")
def use_session():
    reply = session.get()   # Get resource from web service
    return jsonify(reply)

这里session会在启动时创建，use_session()可以访问。

不过，我很难在 Django 中进行同样的设置。创建会话的首选位置是哪里？

Answer 1

相当于你在 Django 中的 Flask 代码是将相同的逻辑放在 views.py 文件中：

# yourapp/views.py
from django.http import HttpResponse
from requests import Session

session = Session()
session.post('https://httpbin.org/post')  # Setup Session by logging in


def use_session(request):
    reply = session.get('https://example.com')  # Get resource from web service
    return HttpResponse(reply.content, status=reply.status_code)

# yourproject/urls.py
from django.urls import path
from yourapp.views import use_session


urlpatterns = [
    path('', use_session)
]

该对象将在您启动服务器时创建。

这种方法的一个问题是，在实际部署中，您通常会运行应用程序的多个副本（不管是 Flask 还是 Django 或任何其他框架）以避免线程阻塞，在相同的服务器或有多个服务器，每个副本最终都会有自己的会话，这可能工作正常，但可能会出现问题。

在这种情况下，您可以在多个进程之间共享一个 Python 对象¹，方法是使用 pickle 模块对其进行序列化并将字节数据存储在数据库中。存储数据的好地方是 Redis 或 Memcached，但也可以使用 Django 的 ORM：

# yourapp/models.py
from django.db import models


class Session(models.Model):
    pickled = models.BinaryField()

# yourapp/views.py
import pickle

from django.http import HttpResponse
from requests import Session

from . import models


def use_session(request):
    # Load the pickled session from the database
    session_db_obj = models.Session.objects.first()

    if session_db_obj:
        # Un-pickle the session
        session = pickle.loads(session_db_obj.pickled)
    else:
        # Create a new session
        session = Session()
        session.post('https://httpbin.org/post')  # Setup Session by logging in

        # Create the database object, pickle the session and save it
        session_db_obj = models.Session()
        session_db_obj.pickled = pickle.dumps(session)
        session_db_obj.save()

    reply = session.get('https://example.com')  # Get resource from web service
    return HttpResponse(reply.content, status=reply.status_code)

---

¹：不是任何物体都可以可靠地腌制和解封，小心！

Answer 2

设置它的最佳位置可能是settings.py，因为它是在应用程序初始化之前调用的，您可以从那里轻松导入代码。

话虽如此，您可能希望研究连接池或在会话顶部有一个包装器，以便在失败时重新创建它。网络并不像看起来那么可靠，如果您打算让会话长时间运行，则会增加会话在某个时间点停止的可能性。