django + pycharm + mysql  + postman

 1401  django-admin.py startproject db1405  cd db1413  python manage.py startapp cs

from django.db import models
class People(models.Model):name = models.CharField(max_length=10, help_text='姓名')sex = models.SmallIntegerField(default=0, help_text="性别")age = models.SmallIntegerField(default=0, help_text='年龄')address = models.CharField(default='', max_length=128, help_text='地址')

 1416  python manage.py makemigrations1417  python manage.py migrate cs

from django.core.management.base import BaseCommand
from cs.models import People
import randomclass Command(BaseCommand):""""""def handle(self, *args, **options):spe = 500objs = list()for i in range(6000000):age = random.randint(1, 70)sex = random.randint(0, 1)objs.append(People(name=str(i), age=age, sex=sex))if i % 500 != 0:continuePeople.objects.bulk_create(objs)objs = list()print(i)

python manage.py create_people

from django.shortcuts import render
from django.views import View
from django.http.response import JsonResponse
from cs.models import People
import gevent
from gevent.pool import Pool
import asyncio
from concurrent.futures import ThreadPoolExecutor, as_completed
from django.db.transaction import atomic# Create your views here.
import timeclass DbViews(View):def get_count(self, age):return age, People.objects.filter(age=age).count()async def gets(self, age):count = People.objects.filter(age=age).countreturn count()async def get_async_count(self, age):print("***age***", age, time.time())age_count = await self.gets(age)print("***age***", age, time.time())return age, age_countdef gevent_pool(self, ages):ages_detail = dict()pool = Pool()ret = list()for age in ages:t = pool.spawn(self.get_count, age)ret.append(t)gevent.joinall(ret)for t in ret:age, age_count = t.valueages_detail.update({age: age_count})return ages_detaildef cur_get(self, ages):ages_detail = dict()for age in ages:age_count = People.objects.filter(age=age).count()ages_detail.update({age: age_count})return ages_detaildef thead_pool(self, ages):ages_detail = dict()thead_poll = ThreadPoolExecutor(max_workers=3)ret = list()for age in ages:t = thead_poll.submit(self.get_count, age)ret.append(t)for t in as_completed(ret):age, age_count = t.result()ages_detail.update({age: age_count})return ages_detaildef async_get(self, ages):ages_detail = dict()loop = asyncio.new_event_loop()asyncio.set_event_loop(loop)ret = list()for age in ages:t = asyncio.ensure_future(self.get_async_count(age))ret.append(t)done, pending = loop.run_until_complete(asyncio.wait(ret))for t in done:age, age_count = t.result()ages_detail.update({age: age_count})return ages_detaildef hclock(self):people = People.objects.select_for_update().filter(id__in=[3,4])with atomic():for i in people:time.sleep(10)print("*******",i.id)i.age += 1i.save()time.sleep(10)def get(self, request):ages = [10, 67, 29]ages_detail = self.hclock()ages_detail = dict()return JsonResponse(ages_detail)

from django.conf.urls import url
from django.contrib import admin
from cs.views import DbViewsurlpatterns = [url('people/', DbViews.as_view(), name='cs')
]

    def get_count(self, age):return age, People.objects.filter(age=age).count()def cur_get(self, ages):ages_detail = dict()for age in ages:age_count = People.objects.filter(age=age).count()ages_detail.update({age: age_count})return ages_detaildef get(self, request):ages = [10, 67, 29]ages_detail = self.cur_get(ages)

    def gevent_pool(self, ages):ages_detail = dict()pool = Pool()ret = list()for age in ages:t = pool.spawn(self.get_count, age)ret.append(t)gevent.joinall(ret)for t in ret:age, age_count = t.valueages_detail.update({age: age_count})return ages_detaildef get(self, request):ages = [10, 67, 29]ages_detail = self.gevent_pool(ages)return JsonResponse(ages_detail)

from gevent import monkey
monkey.patch_all()

During handling of the above exception, another exception occurred:Traceback (most recent call last):File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/utils/autoreload.py", line 227, in wrapperfn(*args, **kwargs)File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/core/management/commands/runserver.py", line 125, in inner_runself.check(display_num_errors=True)File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/core/management/base.py", line 359, in checkinclude_deployment_checks=include_deployment_checks,File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/core/management/base.py", line 346, in _run_checksreturn checks.run_checks(**kwargs)File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/core/checks/registry.py", line 81, in run_checksnew_errors = check(app_configs=app_configs)File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/core/checks/urls.py", line 16, in check_url_configreturn check_resolver(resolver)File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/core/checks/urls.py", line 26, in check_resolverreturn check_method()File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/urls/resolvers.py", line 254, in checkfor pattern in self.url_patterns:File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/utils/functional.py", line 35, in __get__res = instance.__dict__[self.name] = self.func(instance)File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/urls/resolvers.py", line 405, in url_patternspatterns = getattr(self.urlconf_module, "urlpatterns", self.urlconf_module)File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/utils/functional.py", line 35, in __get__res = instance.__dict__[self.name] = self.func(instance)File "/Users/lixiang/projects/py3/lib/python3.6/site-packages/django/urls/resolvers.py", line 398, in urlconf_modulereturn import_module(self.urlconf_name)File "/Users/lixiang/projects/py3/lib/python3.6/importlib/__init__.py", line 126, in import_modulereturn _bootstrap._gcd_import(name[level:], package, level)File "<frozen importlib._bootstrap>", line 994, in _gcd_importFile "<frozen importlib._bootstrap>", line 971, in _find_and_loadFile "<frozen importlib._bootstrap>", line 152, in __exit__File "<frozen importlib._bootstrap>", line 107, in release
RuntimeError: cannot release un-acquired lock

     async def get_async_count(self, age):print("***age***", age, time.time())age_count = await self.gets(age)print("***age***", age, time.time())def async_get(self, ages):ages_detail = dict()loop = asyncio.new_event_loop()asyncio.set_event_loop(loop)ret = list()for age in ages:t = asyncio.ensure_future(self.get_async_count(age))ret.append(t)done, pending = loop.run_until_complete(asyncio.wait(ret))for t in done:age, age_count = t.result()ages_detail.update({age: age_count})return ages_detaildef get(self, request):ages = [10, 67, 29]ages_detail = self.async_get(ages)return JsonResponse(ages_detail)

***age*** 10 1560943042.4748821
***age*** 10 1560943043.3534641
***age*** 67 1560943043.3534899
***age*** 67 1560943044.1488252
***age*** 29 1560943044.148851
INFO 2019-06-19 11:17:24,987 basehttp 3413 123145324937216 "GET /people/ HTTP/1.1" 200 39 ('GET /people/ HTTP/1.1', '200', '39')
***age*** 29 1560943044.9875998

 def thead_pool(self, ages):ages_detail = dict()thead_poll = ThreadPoolExecutor(max_workers=3)ret = list()for age in ages:t = thead_poll.submit(self.get_count, age)ret.append(t)for t in as_completed(ret):age, age_count = t.result()ages_detail.update({age: age_count})return ages_detail
def get(self, request):ages = [10, 67, 29]ages_detail = self.thead_pool(ages)return JsonResponse(ages_detail)

drop table cs_people
create table cs_people(`id` INT AUTO_INCREMENT,`name` varchar(10),`sex` smallint,`age` smallint,`address` varchar(128),PRIMARY KEY (`id`, `age`))PARTITION by range COLUMNS(age)(partition p0 values less than(10),partition p1 values less than(20),partition p2 values less than(30),partition p3 values less than(40),partition p4 values less than(50),partition p6 values less than(60),partition p7 values less than MAXVALUE);

select PARTITION_NAME, TABLE_ROWS from INFORMATION_SCHEMA.PARTITIONS WHERE TABLE_NAME='cs_people';

show index from cs_people