首页   注册   登录
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
推荐学习书目
Learn Python the Hard Way
Python 学习手册
Python Cookbook
Python 基础教程
Python Sites
PyPI - Python Package Index
http://www.simple-is-better.com/
http://diveintopython.org/toc/index.html
Pocoo
值得关注的项目
PyPy
Celery
Jinja2
Read the Docs
gevent
pyenv
virtualenv
Stackless Python
Beautiful Soup
结巴中文分词
Green Unicorn
Sentry
Shovel
Pyflakes
pytest
Python 编程
pep8 Checker
Styles
PEP 8
Google Python Style Guide
Code Style from The Hitchhiker's Guide
V2EX  ›  Python

小白用 flask 做了个接口,运行一段时间,就会报“由于系统缓冲区空间不足或队列已满,不能执行套接字上的操作”

  •  
  •   liwenbest · 49 天前 · 784 次点击
    这是一个创建于 49 天前的主题,其中的信息可能已经有所发展或是发生改变。
    用 flask 做了个简单的查询接口,主要流程是:接收参数后先查询下 mongodb 数据库,如有匹配数据则直接返回,如没有则进行网络数据采集后保存数据到 mongodb 数据库,并返回数据。这接口服务器用 window 系统服务器,现在问题是调用一段时间接口后 会出现"由于系统缓冲区空间不足或队列已满,不能执行套接字上的操作",重启服务器后才能恢复正常使用,不知道有没有更好的优化方法
    6 回复  |  直到 2019-09-24 20:53:28 +08:00
        1
    leishi1313   49 天前 via Android   ♥ 1
    不贴代码没法 debug,建议你查看下有没有哪个函数用了 list,dict 之类的作为默认参数
        2
    roricon   49 天前   ♥ 1
    你看看爬虫采集那部分是不是没设置 timeout,爬虫被 ban 之后一直卡在那里没有及时释放内存。
        3
    liwenbest   49 天前
    #coding:utf-8
    from flask import Flask
    from flask import jsonify
    from flask import request

    import re
    import time,random



    from util import time_to_date,time_to_day
    import json

    from tyc_search import Tycsearch



    class Apibase:
    def __init__(self):

    self.mongodb = Mongobase(GsmongoDB)
    self.mongodb.connect()

    def get_mongoone(self,condition,tname):
    return self.mongodb.select(condition,tname)

    def get_mongoall(self,tname):
    return self.mongodb.all_dt(tname)

    def close_mongo(self):
    return self.mongodb.close()

    class ComplexEncoder(json.JSONEncoder):
    def default(self, obj):
    if isinstance(obj, datetime):
    return obj.strftime('%Y-%m-%d %H:%M:%S')
    elif isinstance(obj, date):
    return obj.strftime('%Y-%m-%d')
    else:
    return json.JSONEncoder.default(self, obj)




    app = Flask(__name__)

    apibase = Apibase()
    tycseach = Tycsearch()



    @app.route('/cha/search', methods=['GET'])
    def get_tasks7():
    #global m

    kw = request.args.get("key")
    kw = kw.replace(' (','(').replace(') ',')').replace(' ','')
    print(f'请求信息:{kw}......')

    try:
    _ = apibase.mongodb.select({'searchkey': {'=':kw}},tname=GsmongoDB['tyc_records'])

    if len(_)==0:
    dic = tycseach.search(kw)
    #print(dic)
    return json.dumps(dic,ensure_ascii=False)
    else:
    dic = _[-1]
    del dic['_id']
    #apibase.close_mongo()
    return json.dumps(dic,ensure_ascii=False)
    except Exception as E:

    print(f'请求失败:原因是:{E}..')
    dic = {}
    dic['code'] = '405'
    dic['urlid'] = ""
    dic['pingfen'] = ''
    dic['searchkey'] = kw
    dic['qymc'] = ''
    dic['请求失败原因'] = '接口调用异常..'

    now_time,now_day = time_to_day(time.time())
    dic['climbdate'] = now_day

    return json.dumps(dic,ensure_ascii=False)




    @app.route('/')
    def index():
    return "Hello, World!"


    if __name__ == '__main__':
    #app.run(debug=True)
    app.run(host="0.0.0.0",port=8090,threaded=True)#h
        4
    liwenbest   49 天前
    V 站这里贴代码有些乱
        5
    ClericPy   49 天前   ♥ 1
    这报错信息这么完整了, 一搜一大把啊... 写程序在初级阶段的时候, 优雅的选择往往是先搜再问
    代码也没贴, 只能猜测是你爬虫或者 mongodb 那边的问题了
    随手搜了次貌似是 Windows 上动态端口被你消耗完了... http://blog.zhaojie.me/2010/08/lack-of-dynamic-ports-when-frequently-open-and-close-socket.html

    Google 这种报错, 中文的不太好说, 但是英文的一般 stackoverflow 上肯定有答案
        6
    celeron533   49 天前   ♥ 1
    这个错误一般是由于端口耗尽,很有可能是使用完成后没有正确的关闭连接
    关于   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   4315 人在线   最高记录 5043   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.3 · 21ms · UTC 01:49 · PVG 09:49 · LAX 17:49 · JFK 20:49
    ♥ Do have faith in what you're doing.