首页 > 其他分享 >aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected

aiohttp.client_exceptions.ServerDisconnectedError: Server disconnected

时间:2023-05-11 19:48:10浏览次数:42  
标签:disconnected aiohttp get Server session total pages page

# 解决:
# 1.aiohttp.TCPConnector(limit=0) => aiohttp.TCPConnector(limit=10)
# 2.添加 timeout=aiohttp.ClientTimeout(total=600)

async def get_data_main():
    # 初始化数据库
    # db_utils.init_db('auto_search_uat.db')

    set_logging.set_get_data_log()

    db_utils.clear_data('auto_search_uat.db')
    # 计算code_info的总页数
    try:
        async with  aiohttp.ClientSession(connector=aiohttp.TCPConnector(limit=12), timeout=aiohttp.ClientTimeout(total=600),headers=header) as session:
            get_data_api = GetDataApi()
            total_pages = get_data_api.get_total_pages()

            logger.info(f'total_pages:{total_pages}')

            # taks1 = [asyncio.ensure_future(get_code_info(page, session)) for page in range(1, total_pages[1] + 1)]
            # taks2 = [asyncio.ensure_future(get_serial_info(page, session)) for page in range(1, total_pages[0] + 1)]
            # taks3 = [asyncio.ensure_future(get_product_model(page, session)) for page in range(1, total_pages[2] + 1)]
            taks4 = [asyncio.ensure_future(get_keywork(page, session)) for page in range(1, total_pages[3] + 1)]

            # taks1.extend(taks2)
            # taks1.extend(taks3)
            # taks1.extend(taks4)
            await asyncio.gather(*taks4)
    except  ContentTypeError as e:
        logger.exception(e)

参考:
1.https://blog.csdn.net/zhb_feng/article/details/118081444

标签:disconnected,aiohttp,get,Server,session,total,pages,page
From: https://www.cnblogs.com/czzz/p/17392011.html

相关文章

  • jumpserver使用
     1页面展示⚓︎页面左侧为功能菜单区,第一次登录默认展示仪表盘界面。右上方区域为功能按钮,可以快速跳转站内信、Web终端、工单、系统设置等功能。可以在图示序号1的位置,进行功能视图的切换。2功能说明⚓︎序号名称说明1控制台管理员操作入口,通过控制台,管理......
  • SQL Server非默认实例、默认端口、更改端口后 进行发布订阅 配置
    角色服务器名称实例名称端口发布服务器TEST1mysqlserver14333订阅服务器TEST2mysqlserver14333    解决办法:需要在A和B服务器上分别配置对方的数据库别名操作:SQLServer网络配置->SQLNativeClient10.0配置->别名->新建别名  要求......
  • k8s证书续签及异常:You must be logged in to the server
    1、证书续签(k8smaster节点执行):  #备份kubernetes配置sudocp-r/etc/kubernetes/etc/kubernetes_bak#更新证书sudokubeadmcertsrenewall#查看证书过期时间sudokubeadmcertscheck-expiration#删除conf文件sudorm-rf/etc/kubernetes/*.conf#重新生......
  • 如何用 Serverless 一键部署 Stable Diffusion?
    思路其实很简单,我们只需要将镜像里面的动态路径映射到NAS文件存储里面即可,利用NAS独立存储文件模型,扩展,语言包等,并且我们可以为管理NAS单独配置一个可视化的后台,用简单的文件上传删除的方式管理我们的文件,为此我们需要展开打镜像的脚本,为了完成全套的流程我们接下来盘一下......
  • Linux网络编程:socket实现client/server通信
    一、问题引入阅读UNIX网络编程卷1:套接字联网API第3版的前4个章节,觉得有必要对书籍上的源码案例进行复现,并推敲TCP的C/S通信过程。二、解决过程2-1server#include<sys/types.h>#include<sys/socket.h>#include<stdio.h>#include<netinet/in.h>#include<arpa/inet.h......
  • ubuntu server版操作系统安装步骤记录
    组内有一个项目支持的时centos的操作系统,后续因为有ubuntu的需求,需要测一下ubuntun操作系统的兼容性,测试前期需要手动为测试服务器装ubuntu的操作系统,因此,这里记录一下自己装ubuntun操作系统的步骤由于项目使用的是ubuntu是18.04.6版本,这里就只记录的是此版本的安装步骤1、下载u......
  • MSSqlServer 出错 9003 错误
      MSSqlServer出错9003错误传递给数据库'PerDB'中的日志扫描操作的日志扫描号(227783:55280:433)无效。此错误可能指示数据损坏,或者日志文件(.ldf)与数据文件(.mdf)不匹配。如果此错误是在复制期间出现的,请重新创建发布。否则,如果该问题导致启动期间出错,请从备份还原......
  • 用sql语句实现sqlserver不同库间表相互同步
    同步表的方式有很多种因为不想太过于麻烦所以就用存储过程来实现某些表同步createproccopytbaleas--表名declare@namenvarchar(50)--创建表declare@createtablenvarchar(200)--删除表declare@deletetablenvarchar(200)--定义游标declaretabnameCURSORF......
  • GeoServer发布图层栅格格式设置样式
    最近工作中使用到了geoserver发布tif图,发布图层后需要给图层设置样式。发布图层就不在这里说了,可以参考其他博客,主要记录一下编写图层样式。一、介绍1、图层类型在geoserver中图层类型分为以下几类:我们可以在管理界面中查看我们发布的图层类型,后面写样式时需要根据我......
  • SQLSERVER获取汉字拼音码
     用户的输入经常用到拼音码选择器 --调用方法select dbo.wsh_GetPY('汉字')ALTERFUNCTION[dbo].[wsh_GetPY](@strNVARCHAR(4000))RETURNSNVARCHAR(4000)ASBEGINDECLARE@WORDNCHAR(1),@PYNVARCHAR(4000)SET@PY=''WHILELEN(@STR)>0BEGI......