• Django信号
  • 内置信号
  • 自定义信号
• 执行原生SQL
• 自定制命令
  • 步骤

Django信号

django自带一套信号机制来帮助我们在框架的不同位置之间传递信息。
简单的说，当某一事件发生时，信号系统可以允许一个或多个发送者(senders)将通知或信号(siganls)发送给一组接收者(receivers)。有内置信号(执行构造方法前，对象保存前，请求来前)和自定义信号两种方式

内置信号

# 内置信号使用(当user表创建用户，就给用户发个邮件)
	1 写个函数   #放到__init__里
        from django.db.models.signals import pre_save
        import logging
        def callBack(sender, **kwargs):
            logging.debug('%s创建了一个%s对象'%(sender._meta.model_name,kwargs.get('instance').title))

        
     2 绑定内置信号   
		pre_save.connect(callBack)
	3 等待触发
    
    
 # 内置信号
    from django.db.models.signals import pre_save
    from django.dispatch import receiver
    @receiver(pre_save)
    def my_callback(sender, **kwargs):
        print("对象创建成功")
        print(sender)
        print(kwargs)

内置信号的种类

# 内置信号：
	#Model signals
    pre_init                    # django的modal执行其构造方法前，自动触发
    post_init                   # django的modal执行其构造方法后，自动触发
    pre_save                    # django的modal对象保存前，自动触发
    post_save                   # django的modal对象保存后，自动触发
    pre_delete                  # django的modal对象删除前，自动触发
    post_delete                 # django的modal对象删除后，自动触发
    m2m_changed                 # django的modal中使用m2m字段操作第三张表（add,remove,clear）前后，自动触发
    class_prepared              # 程序启动时，检测已注册的app中modal类，对于每一个类，自动触发
Management signals
    pre_migrate                 # 执行migrate命令前，自动触发
    post_migrate                # 执行migrate命令后，自动触发
Request/response signals
    request_started             # 请求到来前，自动触发
    request_finished            # 请求结束后，自动触发
    got_request_exception       # 请求异常后，自动触发
Test signals
    setting_changed             # 使用test测试修改配置文件时，自动触发
    template_rendered           # 使用test测试渲染模板时，自动触发
Database Wrappers
    connection_created          # 创建数据库连接时，自动触发

自定义信号

	#1 定义信号（一般创建一个py文件）（toppings，size 是接受的参数）

    import django.dispatch
    pizza_done = django.dispatch.Signal(providing_args=["toppings", "size"])
    # 2 注册信号
    def callback(sender, **kwargs):
        print("callback")
        print(sender,kwargs)
    pizza_done.connect(callback)
# 3 触发信号
    from 路径 import pizza_done
    pizza_done.send(sender='seven',toppings=123, size=456)
    
    
    
# 自定义信号干过什么？
	-做双写一致性的缓存更新
    https://www.cnblogs.com/zjyao/p/17527227.html

执行原生SQL

https://www.cnblogs.com/zjyao/p/17299003.html#python操作mysql

需要借助于第三方模块，pymysql模块。
1. 获取连接对象，conn=pymysql.connect(ip,port,用户,密码,库,字符编码)， 2.获取游标对象cursor = conn.cursor()， 3.cursor.execute('sql语句')，这个值是影响的行数， 4.获取执行结果：cursor.fetchall()，或者 4.提交：conn.commit()

自定制命令

每次在启动Django服务之前，我们都会在终端运行python manage.py xxx的管理命令。其实我们还可以自定义管理命令，这对于执行独立的脚本或任务非常有用，比如清除缓存、导出用户邮件清单或发送邮件等等。

自定义的管理命令不仅可以通过manage.py运行，还可以通过Linux或Celery的crontab服务将其设成定时任务。本文主要讲解如何自定义Django-admin命令，并提供一些演示案例。

步骤

自定义Django-admin命令一共分三步：创建文件夹布局、编写命令代码和测试使用。
1.创建文件夹布局

自定义的Django-admin管理命令本质上是一个python脚本文件，它的存放路径必须遵循一定的规范，一般位于app/management/commands目录。整个文件夹的布局如下所示：

 app01/
     __init__.py
     models.py
     management/          #在app下创建management包
         __init__.py
         commands/         #在management包下创建commands包
             __init__.py
             _private.py # 以下划线开头文件不能用作管理命令
             my_commands.py # 这个就是自定义的管理命令脚本，文件名即为命令名
     tests.py
     views.py


# 注意：
-management和commands每个目录下都必须有个__init__.py空文件，表明这是一个python包。另外以下划线开头的文件名不能用作管理命令脚本。
-management/commands目录可以位于任何一个app的目录下，Django都能找到它。
一般建议每个python脚本文件对应一条管理命令。

2.编写命令代码

每一个自定义的管理命令本质是一个Command类, 它继承了Django的Basecommand或其子类, 主要通过重写handle()方法实现自己的业务逻辑代码，而add_arguments()则用于帮助处理命令行的参数，如果运行命令时不需要额外参数，可以不写这个方法。

 from django.core.management.base import BaseCommand
 
 class Command(BaseCommand):
     # 帮助文本, 一般备注命令的用途及如何使用。
     help = 'Some help texts'
 
     # 处理命令行参数，可选
     def add_arguments(self, parser):
        pass
 
     # 核心业务逻辑
     def handle(self, *args, **options):
         pass

3.测试案例：检查数据库连接是否已就绪

无论你使用常规方式还是Docker在生产环境中部署Django项目，你需要确保数据库连接已就绪后才进行数据库迁移(migrate)的命令(Docker-compose的depends选项并不能确保这点)，否则Django应用程序会出现报错。

这时你可以自定义一个wait_for_db的命令，如下所示：

 # app/management/commands/wait_for_db.py
 import time
 from django.db import connections
 from django.db.utils import OperationalError
 from django.core.management import BaseCommand
 
 
 class Command(BaseCommand):
     help = 'Run data migrations until db is available.'
 
     def handle(self, *args, **options):
         self.stdout.write('Waiting for database...')
         db_conn = None
         while not db_conn:
             try:
                 # 尝试连接
                 db_conn = connections['default']
             except OperationalError:
                 # 连接失败，就等待1秒钟
                 self.stdout.write('Database unavailable, waiting 1 second...')
                 time.sleep(1)
 
         self.stdout.write(self.style.SUCCESS('Database available!'))

命令： python manage.py wait_for_db