from django import forms

class UploadFileForm(forms.Form):
    title = forms.CharField(max_length=50)
    file = forms.FileField()

from django.http import HttpResponseRedirect
from django.shortcuts import render
from .forms import UploadFileForm

def upload_file(request):
    if request.method == 'POST':
        form = UploadFileForm(request.POST, request.FILES)
        if form.is_valid():
            # 获取上传的文件
            uploaded_file = request.FILES['file']
            # 在这里可以添加处理上传文件的代码
            # ...
            # 重定向或返回成功响应
            return HttpResponseRedirect('/success/url/')
    else:
        form = UploadFileForm()
    return render(request, 'upload.html', {
        'form': form
    })

<form method="post" enctype="multipart/form-data">
    {% csrf_token %}
    {{ form.as_p }}
    <button type="submit">上传文件</button>
</form>

from django.urls import path
from .views import upload_file

urlpatterns = [
    path('upload/', upload_file, name='upload_file'),
]

from pymongo import MongoClient

# 连接到MongoDB
client = MongoClient('mongodb://localhost:27017/')

# 选择或创建数据库
db = client['test_database']

# 选择或创建集合（类似于SQL中的表）
collection = db['test_collection']

# 插入文档
document = {'name': 'Alice', 'age': 25, 'address': '123 Fake St'}
collection.insert_one(document)

# 查询文档
query = {'name': 'Alice'}
result = collection.find_one(query)
print(result)

# 更新文档
update = {'$set': {'age': 30}}
collection.update_one(query, update)

# 再次查询文档以验证更新
result = collection.find_one(query)
print(result)

# 删除文档
collection.delete_one(query)

# 关闭连接
client.close()

from pymongo import MongoClient

# 连接到MongoDB
client = MongoClient('mongodb://localhost:27017/')

# 选择数据库
db = client['test_database']

# 选择集合（类似于SQL中的表）
collection = db['test_collection']

# 插入文档
collection.insert_one({'name': 'Alice', 'age': 25, 'location': 'Wonderland'})

# 查询文档
alice = collection.find_one({'name': 'Alice'})
print(alice)

# 更新文档
collection.update_one({'name': 'Alice'}, {'$set': {'age': 30}})

# 删除文档
collection.delete_one({'name': 'Alice'})

# 关闭连接
client.close()

from pymongo import MongoClient
from pymongo.ssl_context import SSLContext

# 创建SSL上下文
ssl_context = SSLContext(ssl.PROTOCOL_TLS)
ssl_context.options |= ssl.OP_NO_TLSv1 | ssl.OP_NO_TLSv1_1 | ssl.OP_NO_TLSv1_2  # 禁用旧的TLS版本
ssl_context.set_ciphers("TLS13")  # 仅允许TLS 1.3

# 连接到MongoDB服务器
client = MongoClient('mongodb://username:password@server_address:27017/database_name', ssl_context=ssl_context)

# 使用client进行操作...

# 在机器A上
mongod --port 27017 --dbpath /srv/mongodb/db0 --replSet rs0 --bind_ip 0.0.0.0

# 在机器B上
mongod --port 27017 --dbpath /srv/mongodb/db1 --replSet rs0 --bind_ip 0.0.0.0

# 在机器C上
mongod --port 27017 --dbpath /srv/mongodb/db2 --replSet rs0 --bind_ip 0.0.0.0

mongo --host A_IP --port 27017

rs.initiate(
  {
    _id: "rs0",
    members: [
      { _id: 0, host: "A_IP:27017" },
      { _id: 1, host: "B_IP:27017" },
      { _id: 2, host: "C_IP:27017", arbiterOnly: true }
    ]
  }
)

rs.status()

# 对于一对多关系
Blog.objects.select_related('author').all()

# 对于多对多关系
Entry.objects.prefetch_related('blog').all()

# 只获取id和title字段
Entry.objects.only('id', 'title').all()

# 获取除了title以外的所有字段
Entry.objects.defer('title').all()

Entry.objects.cache().all()

Entry.objects.extra(select={'blog_title': "blog.name"}, order_by=['-blog_title'])

Entry.objects.raw('SELECT * FROM blog_entry WHERE author_id = %s', [author_id])

class Entry(models.Model):
    ...
    author = models.ForeignKey(Author, on_delete=models.CASCADE, db_index=True)
    ...

from django.core.cache import cache

def get_popular_entries():
    popular_entries = cache.get('popular_entries')
    if popular_entries is None:
        popular_entries = Entry.objects.all().order_by('-popularity')[:10]
        cache.set('popular_entries', popular_entries, 300)
    return popular_entries

from asgiref.sync import async_to_sync
from django.http import HttpResponse
from django.views import View

import time

async def long_running_task(request):
    # 执行长时间运行的任务
    await asyncio.sleep(5)
    return HttpResponse("Done")

class LongRunningTaskView(View):
    def get(self, request):
        return async_to_sync(long_running_task)(request)

from pymongo import MongoClient

# 连接MongoDB
client = MongoClient('mongodb://localhost:27017/')

# 选择数据库
db = client['example_db']

# 选择集合（类似于SQL中的表）
collection = db['example_collection']

# 插入文档
post = {"name": "老吕", "title": "MongoDB 入门"}
collection.insert_one(post)

# 查询文档
query = {"name": "老吕"}
document = collection.find_one(query)
print(document)

# 关闭连接
client.close()

from django_ldapdb_backends.ldap import LDAP
from django_ldapdb_backends.models import AbstractLDAPBase
from django.db import models

# 定义一个LDAP用户模型
class LDAPUser(AbstractLDAPBase):
    # 这里的字段需要与LDAP中的对象类别相对应
    objectClass = ('top', 'person', 'organizationalPerson', 'inetOrgPerson')
    commonName = models.CharField(max_length=128, blank=True)
    surname = models.CharField(max_length=128, blank=True)
    givenName = models.CharField(max_length=128, blank=True)
    initials = models.CharField(max_length=128, blank=True)
    displayName = models.CharField(max_length=128, blank=True)
    # 其他字段...

    # 定义一个方法用于同步LDAP数据到数据库
    def sync_to_db(self):
        # 实现同步逻辑
        pass

# 使用LDAPUser模型进行查询
user = LDAPUser.objects.get(uid='john_doe')
user.surname = 'Doe'
user.save()  # 这将更新LDAP中的条目

pip install django-cron

INSTALLED_APPS = (
    # ...
    'django_cron',
    # ...
)

python manage.py crontab add

from django_cron import cron

@cron.register
def my_scheduled_job():
    # 你的任务代码
    print('This job is run every minute')

pip install apscheduler

from apscheduler.schedulers.background import BackgroundScheduler

def my_job():
    print("APScheduler is working!")

scheduler = BackgroundScheduler()
scheduler.add_job(my_job, 'interval', minutes=1)
scheduler.start()