flask异步（flask异步回调服务）

本篇文章给大家谈谈flask异步，以及flask异步回调服务对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

• 1、Tornado与flask的特点和区别有哪些
• 2、flask配置生产环境
• 3、Flask 实现异步服务

Tornado与flask的特点和区别有哪些

这两个词是完全不同的意思。

一、tornado的用法。

tornado的意思是龙卷风。

龙吸水是来自积雨云底部下垂的漏斗状云及其所伴随的非常强烈的旋风。它是一种破坏力最强的小尺度天气系统，又称龙卷风，由于漏斗云内气压很低，具有很强的吮吸作用，当漏斗云伸到陆地表面时，可把大量沙尘等吸到空中，形成尘柱，称陆龙卷；当它伸到海面时，能吸起高大水柱，称海龙卷（或水龙卷）。海龙卷一般较陆龙卷弱，水平范围也比陆龙卷小。龙卷风这种自然现象是云层中雷暴的产物，具体的说，龙卷风就是雷暴巨大能量中的一小部分在很小的区域内集中释放的一种形式。

龙卷风形成的过程：地面上的水吸热变成水蒸气，上升到天空蒸汽层上层，由于蒸汽层上层温度低，水蒸气体积缩小比重增大，蒸汽下降，由于蒸汽层下面温度高，下降过程中吸热，再度上升遇冷，再下降，如此反复气体分子逐渐缩小，最后集中在蒸汽层底层，在底层形成低温区，水蒸气向低温区集中，这就形成云。云团逐渐变大，云内部上下云团上下温差越来越小，水蒸气分子升降幅度越来越大，云内部上下对流越来越激烈，云团下面上升的水蒸气直向上升，水蒸气分子在上升过程中受冷体积缩小越来越小，呈漏斗状。上升的水蒸气分子受冷体积不断缩小，云下气体分子不断补充空间便产生了大风，由于水蒸气受冷体积缩小时，周围补充空间的气体来时不均匀便形成龙卷风。

由雷暴云底伸展至地面的漏斗状云(龙卷)产生的强烈的旋风，其风力可达12级以上，最大可达每秒300米以上。一般伴有雷阵雨，有时也伴有冰雹。

空气绕龙卷的轴快速旋转，受龙卷中心气压极度减小的吸引，近地面几十米厚的一薄层空气内，气流被从四面八方吸入涡旋的底部，并随即变为绕轴心向上的涡流。龙卷中的风总是气旋性的，其中心的气压可以比周围气压低百分之十，一般可低至400hPa，最低可达200hPa。龙卷风具有很大的吸吮作用，可把海(湖)水吸离海(湖)面，形成水柱，然后同云相接，俗称“龙取水”。

龙卷风这种自然现象是云层中雷暴的产物，具体的说，龙卷风就是雷暴巨大能量中的一小部分在很小的区域内集中释放的一种形式消罩。

能产生龙卷风的积雨云都是巨型积雨云，在云-天放电过程中，云顶的正电量要比云底的负电量大得多。经云内闪电中和后则云底的负电荷不足，携带大量正电荷的云团跟地面形成强大电场。在静电引力的作用下，携带正电荷云团从云底向下伸出，携带负电荷的空气从四周汇聚而进行电中和。在积雨云的底部首先出现一个漏斗云，其周围的空气高速地旋转。

如果云中的正电量足够大，漏斗云会迅速地向地面或水面延伸，当它与地表相接后就形成了龙卷风。龙卷风的云柱是向下运动的携带大量正电荷的云团气流，云柱与地表之间存在着强大的电场，该电场虽然不足以引发闪电，但却能够使地面或水面产生很强的负离子流（电子流）。在负离子流的带动下，空气迅速上升而形成一个低气压区，在大气压的作用下四周空气向低气压中心部位汇聚，汇聚来的空气在负离子流的作用下加速上升，汇聚气流受地球自转偏向力的影响，龙卷风发生在北半球则逆时针旋转，发生在南半球则顺时针旋转。空气的上述运动，使龙卷风底部的气压越来越低，风速也越来越强。

二、flask的意义。

flask的含义是烧瓶。

烧瓶通常有平底和圆底之分。平底的叫做平底烧瓶，圆底的叫圆底烧瓶。

烧瓶通常具有圆肚细颈的外观，与烧杯明显地不同。它的窄口是用来防止溶液溅出或是减少溶液的蒸发，并可配合橡皮塞的使用，来连接其它的玻璃器材。当溶液需要长时间的反应或是加热回流时，一般都会选择使用烧瓶作为容器。烧瓶的开口没有像烧杯般的突出缺口，倾倒溶液时更易沿外壁流下，所以通常都会用玻棒轻触瓶口以防止溶液沿外壁流下。烧瓶因瓶口很窄，不适用玻棒搅拌，若需要搅拌时，可以手握瓶口微拿脊闹转手腕即可顺利搅拌均匀。若加热回流时，则可於瓶内放入磁搅拌子，以加热搅拌器加以搅拌。烧瓶随著其外观的不同可分平底烧瓶和圆底烧瓶两种。左上图为一平底烧瓶，右上图则为一圆底烧瓶。通常平底烧瓶用在室温下的反应，而圆底烧瓶则用在较高温的反应。这是因野则为圆底烧瓶的玻璃厚薄较均匀，可承受较大的温度变化。

烧瓶（英语：Laboratory flask）是实验室中使用的有颈玻璃器皿，用来盛液体物质。因可以耐一定的热而被称作烧瓶。 在化学实验中，试剂量较大而又有液体物质参加反应时使用的容器。烧瓶都可用于装配气体发生装置。

flask配置生产环境

书接上文 flask与SQLAlchemy ，我们了解到

这一步的的测试可以看 一个小型的资源管理站

这里与直接上结果。

原flask使用的WSGI是python，但是很明显python作为HTTP解释器是效率低下的。而并耐清且，直接运行flask也是非常糟心的。比如集中配置，比如多进程多线程，比如socket通信，比如log管理，比如进程管理

将此文件放置在项目的根目录，并创建文件夹uwsgi

详见

flask+uWSGI已经能实现webserver的功能了，但是更加优秀的weberver还需要nginx的辅助。

Nginx（发音同engine x）是异步框架的网页服务器，也可以用作反向代理、负载平亩陵衡器和HTTP缓存。

还有写拓展处理 主要看服务配置

这里 nginx -s reload 已经完成了服务配置。如果不想配置服务，直接到nginx根目录运行 ./sbin/nginx

这里给绝前大家推荐一个不错的平台：Cloudflare

Cloudflare

在使用之前我们需要更换自己的顶级域名代理商，这一步此处以腾讯云截图：

跳过注册等过程，我们直接进入域名管理界面，看到

然后创建密钥

xxx.pem

xxx.key

再扔到服务器上去。

最后再配置nginx

总结配置flask一般形态的生产环境nginx+uwsgi+flask

回到目录

Flask 实现异步服务

Flask的服务，默认是同步的，在接收多个请求是会发生阻塞的，导致打开页面变的很慢，很卡，如下一个flask服务：

# -*- coding: utf-8 -*-

import sys

from seleniumimport webdriver

from  bs4import BeautifulSoup

import time

import json

from pymongoimport MongoClient

from zhimaipimport getdailione

from flaskimport Flask, jsonify, request

#创建一个Flask对象

app = Flask(__name__)

def browserini():

global driver

# 启动浏览器

# ip, exttime = getdailione(3)  #调用芝麻IP 3-6小时

    ip ='47.96.225.239:4111'

    while ip ==0:

# ip, exttime = getdailione(3)

        ip ='47.96.225.239:4111'

        time.sleep(3)

chrome_options = webdriver.ChromeOptions()

chrome_options .add_argument('--headless')

chrome_options.add_argument('--disable-gpu')

chrome_options.add_argument('--proxy-server=' + ip)

driver = webdriver.Chrome(chrome_options=chrome_options)# 加载浏览器汪乱搭驱动

# driver.set_window_size(1920, 1080)

 困拿   url =''

#flask服务，供单点查询调用

@app.route('/api/search/baseinfo/',methods=['POST'])

def baseinfo():

url =''

    driver.get(url)

search_name = request.form.get('searchname')# 获取表单请求参数

    if(len(search_name)5):

return json.dumps({'error_message':'sorry, please enter the correct company name!'})

else:

print ('query company_name is:',search_name)

element = driver.find_element_by_id('searchkey')#搜索框

 陪大       time.sleep(3)

element.send_keys(search_name)#输入搜索公司名称

        clickbutton = driver.find_element_by_id('V3_Search_bt')#搜索按钮

        clickbutton.click()

#进入搜索公司列表，点击公司链接

        soup = BeautifulSoup(driver.page_source,'lxml')

num = soup.find('span', {'id':'countOld'}).find('span', {'class':'text-danger'}).text.strip()# 搜寻到该公司数量列表

        if  '0'==num:

print u'抱歉！查询不到该公司信息,请确认后重新获取!'

            return json.dumps({'message':u'抱歉！查询不到该公司信息,请确认后重新获取!'})

else:

hrefbutton = driver.find_element_by_class_name('ma_h1')#找到第一个公司链接点击

            hrefbutton.click()

handles = driver.window_handles#当前所有句柄

            print handles

first_handles = handles[0]

driver.switch_to.window(handles[1])#将浏览器驱动跳转到当前窗口

#开始解析页面获取基本信息

            soup = BeautifulSoup(driver.page_source)

company_name = soup.find('div', {'id':'company-top'}).find('div',{'class' :'content'}).find('div', {'class':'row title'}).text.strip()#公司名称

#print company_name, type(company_name)

            company_name = company_name.split(' ')[0].split('\n')[0]

#基础信息标签

            baselist = soup.find('section', {'id':'Cominfo'}).find_all('table', {'class':'ntable'})[1]#

            tr_list = baselist.find_all('tr')

# 插入基本信息数据表

            data= json.dumps({

# 注册资本

                'register_capital': tr_list[0].find_all('td')[1].text.strip(),

# 实缴资本

                'real_capital': tr_list[0].find_all('td')[3].text.strip(),

# 经营状态

                'operate_state': tr_list[1].find_all('td')[1].text.strip(),

# 公司名称     

'company_name' : company_name,

# 爬取时间

                'crawl_time': time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))

})

# 关闭新窗口

    driver.close()

driver.switch_to.window(first_handles)# 将浏览器驱动跳转到当前窗口

    return data

if __name__ =='__main__':

try:

# 启动浏览器

# ip, exttime = getdailione(3)  #调用芝麻IP 3-6小时

        ip ='47.96.225.239:4111'

        while ip ==0:

ip, exttime = getdailione(1)

#ip = '47.96.225.239:4111'

            time.sleep(3)

chrome_options = webdriver.ChromeOptions()

chrome_options .add_argument('--headless')

chrome_options.add_argument('--disable-gpu')

chrome_options.add_argument('--proxy-server=' + ip)

driver = webdriver.Chrome(chrome_options=chrome_options)# 加载浏览器驱动

#driver.set_window_size(1920, 1080)

        time.sleep(5)

except:

browserini()

app.run(host='0.0.0.0',port =5008,debug=True,use_reloader=False)

比较简单的实现异步的方式就是借助第三方库：gevent

# -*- coding: utf-8 -*-

from gevent import monkey

from gevent import pywsgi 或者 from gevent.pywsgi import WSGIServer

from flask import Flask

import requests

app = Flask(__name__)

@app.route('/')

def index():

        #具体的处理逻辑

http_server = pywsgi.WSGIServer(('127.0.0.1', 5000), app)

http_server.serve_forever()

[img]

关于flask异步和flask异步回调服务的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。