Python asyncio SSL传输未关闭
Python asyncio是Python标准库中的一个模块，用于编写异步代码。它提供了一种基于事件循环的编程模型，可以实现高效的并发操作。SSL（Secure Sockets Layer）是一种用于保护网络通信安全的协议，它通过加密数据传输来防止数据被窃取或篡改。
在Python asyncio中，可以使用SSL传输来保护网络通信的安全性。SSL传输使用了公钥加密和私钥解密的方式，确保数据在传输过程中的机密性和完整性。当使用SSL传输时，客户端和服务器之间会进行握手过程，交换证书并验证身份，然后建立安全的连接。
然而，在使用Python asyncio进行SSL传输时，有时会出现SSL传输未关闭的情况。这可能是由于代码中没有正确关闭SSL连接导致的。未关闭的SSL连接可能会导致资源泄漏和安全隐患。
为了解决这个问题，可以在代码中显式地关闭SSL连接。可以使用ssl.SSLSocket.shutdown()方法来关闭SSL连接。在使用Python asyncio时，可以在协程执行完毕后，通过调用transport.close()方法来关闭连接。这样可以确保SSL连接被正确关闭，避免资源泄漏和安全问题。
总结起来，Python asyncio SSL传输未关闭是指在使用Python asyncio进行SSL传输时，未正确关闭SSL连接的情况。为了解决这个问题，需要在代码中显式地关闭SSL连接，可以通过调用transport.close()方法来实现。关闭SSL连接可以避免资源泄漏和安全问题的发生。
推荐的腾讯云相关产品：腾讯云SSL证书服务。腾讯云SSL证书服务提供了多种类型的SSL证书，可以保护网站和应用程序的安全性。通过使用腾讯云SSL证书服务，可以轻松地为网站和应用程序添加SSL加密，提供安全的数据传输保护。
产品介绍链接地址：腾讯云SSL证书服务
相关·内容
我正在使用套接字和异步实现服务器实现中的生产者-消费者程序。问题是，在封装在ssl连接中的套接字使用时，异步函数sock_recv()似乎不能正常工作。以下是工作代码。
服务器端
import asyncio
import random
import socket
import ssl
SERVER_ADDRESS = (HOST, PORT) = "127.0.0.1", 8881
async def producer(queue, client_connection, event_loop):
while True:
print("Wai
浏览 2提问于2019-06-22得票数 1
回答已采纳
我正在使用Python3.8 中的asyncio库
我正在创建一个服务器，在“新接受的连接”回调函数中，我想找出新客户机的远程IP地址和端口。
回调函数的参数是StreamReader和StreamWriter各自的一个实例，用于从客户端读取和写入数据。有没有一种直接的方法可以找到流的IP地址和端口？请注意，我希望对SSL和非SSL连接执行此操作。
我在这里创建服务器：
async def create_server(self, new_client_cb, host, port):
srvsocket = socket.socket(socket.AF_INET, socket.SO
浏览 53提问于2020-02-04得票数 2
2回答
尝试从URL下载和处理jpegs。我的问题不是某些URL的证书验证失败，因为这些URL是旧的，可能不再值得信任，但是当我try...except... SSLCertVerificationError时，我仍然会得到回溯。
系统: Linux 4.17.14-arch1-1，python 3.7.0-3，aiohttp 3.3.2
最起码的例子：
import asyncio
import aiohttp
from ssl import SSLCertVerificationError
async def fetch_url(url, client):
try:
as
浏览 0提问于2018-08-24得票数 13
回答已采纳
1回答
我在Fedora 26工作站上使用Python 3.6.2。
下面是一些剪贴簿代码，它演示了我的问题：
编辑:将Sam Hartman的建议添加到代码中。
import asyncio, json
from autobahn.asyncio.websocket import WebSocketClientProtocol, WebSocketClientFactory
class MyClientProtocol(WebSocketClientProtocol):
def onConnect(self, response):
print(response.peer)
浏览 2提问于2017-11-04得票数 2
我正在开发一个Python应用程序，通过安全的websocket协议与运行在本地主机上的服务相结合。下面是一个示例代码：
import json
import asyncio
import websockets
import ssl
import certifi
ssl_context = ssl.create_default_context()
ssl_context.load_verify_locations(certifi.where())
ssl_context.load_default_certs()
query = {
"jsonrpc": "
浏览 0提问于2019-05-06得票数 2
回答已采纳
背景:我正在使用/connect上的websocket端点使用aiohttp编写web服务器。该应用程序最初是通过HTTP提供的(客户端将连接到ws://host/connect)。使用localhost在本地工作，但当我部署到Heroku时，该应用程序是通过HTTPS提供服务的，它不允许客户端连接到不安全的websocket。因此，我尝试更改我的服务器，使其在本地使用HTTPS。现在客户端甚至不能完成与服务器的TLS握手。下面是我的设置： server.py from aiohttp import web
import ssl
app = web.Application()
app.ro
浏览 31提问于2020-03-24得票数 0
回答已采纳
2回答
获取异步服务器以调用另一台服务器
、、、、
因此，我修改了异步客户机和服务器的示例(在这里可以找到：)，我只想让client.py调用serverone.py，然后再调用servertwo.py。
client.py
#!/usr/bin/env python3.4
import asyncio
class EchoClient(asyncio.Protocol):
message = 'This is the Client'
def connection_made(self, transport):
transport.write(self.message.encode())
浏览 2提问于2014-09-03得票数 2
回答已采纳
任何基于discord.py结果错误的python程序：
Traceback (most recent call last):
File "/Users/user/Library/Python/3.9/lib/python/site-packages/aiohttp/connector.py", line 969, in _wrap_create_connection
return await self._loop.create_connection(*args, **kwargs) # type: ignore # noqa
File "/Libr
浏览 20提问于2021-12-07得票数 1
回答已采纳
当我运行这个时，我总是遇到一个错误。它在应答中运行平稳，但当我在vs代码上运行它时，它给了我一个很长的奇怪错误。它说了一些关于证书的事情，我不知道有什么问题。错误：[SSLCertVerificationError：(1，'SSL: CERTIFICATE_VERIFY_FAILED证书验证失败:无法获得本地颁发者证书(_ssl.c:997)')]
import discord
import os
import requests
import json
import random
client = discord.Cli
浏览 24提问于2022-07-19得票数 1
我在下面的代码中遇到了问题，我得到了一个SSLV3握手失败：
import aiohttp
import asyncio
import ssl
def main():
conn = set_conn()
loop = asyncio.get_event_loop()
loop.run_until_complete(get_thing('https://example.com', conn))
@asyncio.coroutine
def get_thing(url, conn):
response = yield from aiohttp.r
浏览 6提问于2015-01-11得票数 4
我重构了一些django代码来做一些web抓取。我为每个要抓取数据的用户启动一个单独的Celery Task。在每个Celery任务中，我使用asyncio和aiohttp为给定的用户进行抓取。 我可以访问我的所有django模型类和方法，但一旦我触发实际的数据库查询，我就会收到如下错误： ...
[2019-02-16 18:04:38,126] WARNING log /home/chrisadmin/anaconda3/lib/python3.6/site-packages/celery/app/trace.py:561: RuntimeWarning: Exception raise
浏览 23提问于2019-02-17得票数 0
我在制作Python时遵循了。现在，我已经完成了最后一步，即运行app.py。
问题是它会永远运行，什么都不会发生。
ssl_context和slack_token都打印出一些有意义的东西：xoxb-XXXXXXXXXXXX-xxxxxxxxxxxx-XXXXXXXXXXXXXXXXXXXXXXXX和<ssl.SSLContext object at 0x00000xxxxxxxxxxx>。
.start()方法(包括获取客户端和令牌)如下所示(包括打印值)：
if __name__ == "__main__":
ssl_context = ssl_lib.
浏览 0提问于2019-10-18得票数 1
回答已采纳
我正在使用带有limited_as_completed方法的aiohttp来加速清除(大约1亿个静态网站页面)。但是，代码会在几分钟后停止，并返回TimeoutError。我尝试了几种方法，但仍然不能阻止raise asyncio.TimeoutError。我可以问一下如何忽略该错误，然后继续吗？
我运行的代码是：
N=123
import html
from lxml import etree
import requests
import asyncio
import aiohttp
from aiohttp import ClientSession, TCPConnector
impor
浏览 1提问于2018-10-30得票数 6
回答已采纳
3回答
我是否必须在我的系统中安装/生成/下载新的证书，还是我可以在python中禁用证书？(ubuntu 18, python 3.7, discord.py latest)
[INFO] [2019.03.05 - 22:58:02] Initializing Discord...
SSL handshake failed on verifying the certificate
protocol: <asyncio.sslproto.SSLProtocol object at 0xf4a9f8ec>
transport: <_SelectorSocketTranspor
浏览 0提问于2019-03-05得票数 1
回答已采纳
我想试用Python3.5.1中的新asyncio模块。下面是我的测试代码：
import asyncio
class EchoClientProtocol:
def __init__(self, message, loop):
self.message = message
self.loop = loop
self.transport = None
def connection_made(self, transport):
self.transport = transport
print(&#
浏览 3提问于2016-06-30得票数 0
1回答
import asyncio
import aiohttp
import socket
def _create_loop():
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
loop = asyncio.get_event_loop()
return loop
async def _create_tasks(loop, URLs, func):
connector = aiohttp.TCPConnector(limit=200,
浏览 2提问于2019-11-17得票数 4
回答已采纳
当我尝试在这段代码中使用框架 (摘自文档)时，我正在使用Python的一些web框架：
import aiohttp
import asyncio
#********************************
# a solution I found on the forum:
# https://stackoverflow.com/questions/50236117/scraping-ssl-certificate-verify-failed-error-for-http-en-wikipedia-org?rq=1
import ssl
ssl._create_default_ht
浏览 19提问于2021-12-05得票数 4
回答已采纳
1回答
最小演示示例：
import asyncio
async def main():
c1_reader, c1_writer = await asyncio.open_connection(host='google.com', port=80)
c1_socket = c1_writer.get_extra_info('socket')
c1_socket.close()
c2_reader, c2_writer = await asyncio.open_connection(host='google.com',
浏览 0提问于2019-07-25得票数 1
回答已采纳
1回答
我是ssl的新手，我使用openssl生成了自签名证书。
openssl req -newkey rsa:2048 -nodes -keyout key.pem -x509 -days 3650 -out certificate.pem
其中服务器具有以下代码。
if __name__ == "__main__":
context = ssl.SSLContext(ssl.PROTOCOL_TLSv1_2)
context.load_cert_chain("/home/rootkit/ssl/certificate.pem",
浏览 1提问于2018-09-07得票数 1
回答已采纳
在尝试运行文档中给出的asyncio hello world代码示例时：
import asyncio
async def hello_world():
print("Hello World!")
loop = asyncio.get_event_loop()
# Blocking call which returns when the hello_world() coroutine is done
loop.run_until_complete(hello_world())
loop.close()
我得到了错误：
RuntimeError: Event loop
浏览 2提问于2017-08-10得票数 66
回答已采纳
所以我的代码看起来像这样：
tasks = [asyncio.ensure_future(self.run(proxy)) for proxy in proxy_list]
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(tasks))
res = [task.result() for task in tasks if task.result()]
async def run(self, proxy):
async with aiohttp.ClientSession() as session
浏览 1提问于2018-11-26得票数 1
我正在尝试访问python3.8中的Slack，但是我无法通过第一步。下面是我的代码：
import slack
slack_token="xoxp-*******-*******-*******-*******"
client = slack.WebClient(slack_token)
client.chat_postMessage(
channel="XXXXXXXXXX",
text="Hello from your app! :tada:"
)
print('hello')
下面是错误：
Trace
浏览 1提问于2020-01-19得票数 5
我只是在摆弄sqlalchemy ORM功能 我能够让它在我的主应用程序上工作，但当我创建了一个单独的文件test.py来测试某些东西时，我一直收到事件循环关闭的错误： Exception ignored in: <function Connection.__del__ at 0x7f7041c07310>
Traceback (most recent call last):
File "/home/krypt/Documents/Projects/app/env/lib/python3.9/site-packages/aiomysql/connection.py&#
浏览 41提问于2021-06-26得票数 0
回答已采纳
我在python中使用内置库(如webSocket )实现了WebSocketServerFactory服务器，如下代码所示：
from autobahn.asyncio.websocket import WebSocketServerProtocol, WebSocketServerFactory
import ssl
import asyncio
sslcontext = ssl.SSLContext(ssl.PROTOCOL_SSLv23)
sslcontext.load_cert_chain(self.sslcert, self.sslkey)
factory = WebSoc
浏览 4提问于2021-11-28得票数 0
在下面的例子中：
loop = asyncio.get_event_loop()
loop.create_task(client()) # Does no start until run_server ends
await server()
# await f()
..。对服务器的调用导致客户端被阻塞。特别是，它被卡在了
await loop.sock_accept(sock)
直到server()退出，client()才会启动。为什么？
用不同的异步函数替换await server()：
#await server()
await f(
浏览 3提问于2022-05-19得票数 1
回答已采纳
我写了一个使用asyncio和aiohttp发布事件的程序。当我在本地运行这个程序时，它可以工作。我可以张贴10k事件没有问题。然而，我把整个代码库SCPed到了一台远程机器上，在那台机器上我发布的事件不能超过15个，否则会出现这个错误：
RuntimeError: Event loop is closed
Exception ignored in: <coroutine object Poster.async_post_event at 0x7f4a53989410>
Traceback (most recent call last):
File "/home/bli
浏览 0提问于2016-11-04得票数 1
刚接触到蟒蛇。尝试从运行以下示例程序，但得到了错误
$ python coro.py
File "coro.py", line 3
async def compute(x, y):
^
SyntaxError: invalid syntax
下面是coro.py中的代码片段
import asyncio
async def compute(x, y):
print("Compute %s + %s ..." % (x, y))
await asyncio.sleep(1.0)
return x + y
浏览 1提问于2016-04-09得票数 1
回答已采纳
我只是试着看一下aiohttp的例子，但是我得到了第一个错误：
import aiohttp
import asyncio
async def fetch(session, url):
async with session.get(url) as response:
return await response.text()
async def main():
async with aiohttp.ClientSession() as session:
html = await fetch(session, 'http://python
浏览 0提问于2019-06-17得票数 0
回答已采纳
在探索Python3.4.0的异步模块时，我尝试使用类外部的asyncio.coroutine方法创建一个类。
我的工作代码在下面。
import asyncio
class Foo():
@asyncio.coroutine
def async_sleep(self):
print('about to async sleep')
yield from asyncio.sleep(1)
@asyncio.coroutine
def call_as(self):
print('about
浏览 3提问于2014-04-25得票数 5
回答已采纳
import httpx
import asyncio
baseUrl = "https://ec.europa.eu/tools/eudamed/api/devices/udiDiData"
params = {
"page": "0",
"pageSize": "25",
"size": "25",
"sort": ["primaryDi,ASC", "versionNumber,DESC"],
浏览 40提问于2022-02-16得票数 1
1回答
目前，我正在将一些遗留代码迁移到异步，并遇到有关SSL握手的问题。
我正在创建一个SSL服务器：
import os
import socket
import asyncio
from myexample import Connection
storage_path = '.' # Path where certificates are stored (self-signed)
ssl_context = ssl.SSLContext(ssl.PROTOCOL_TLSv1_2)
ssl_context.load_verify_locations(
cafile
浏览 9提问于2020-08-08得票数 0
回答已采纳
1回答
调试异步内存泄漏
、、、
如何调试asyncio (使用aiohttp)应用程序以发现内存泄漏？
应用程序: 100个异步协程，从Redis读取消息，进行一些外部API http调用，并将结果保存到数据库中。
这里的问题是:在更大的消息数量(10k-20k)上，应用程序使用的RAM内存在每条消息之后都会增加。
使用objgraph进行调试，如：
print(objgraph.show_growth(limit=100))
在每条新消息后显示完全相同的结果：
weakref 6163 +4
dict 19192
浏览 29提问于2019-10-30得票数 4
1回答
我想要快速连接到许多不同站点的列表。我正在使用asyncio以异步方式完成此操作，现在希望添加一个超时，用于在连接响应时间过长时忽略它们。
我如何实现这一点？
import ssl
import asyncio
from contextlib import suppress
from concurrent.futures import ThreadPoolExecutor
import time
@asyncio.coroutine
def run():
while True:
host = yield from q.get()
if not hos
浏览 1提问于2015-04-21得票数 20
回答已采纳
2回答
我有一个简单的Python (3.6) Tornado (4.5.2)服务器示例，我正在尝试添加ssl证书以进行测试。我已确定它正在查找密钥和csr文件。下面是我的代码看起来是什么样子，后面有一个堆栈跟踪，后面详细描述了错误。有没有人遇到过这个问题或者解决过这个问题？
import tornado.httpserver
import tornado.ioloop
import tornado.web
class indexHandler(tornado.web.RequestHandler):
def get(self):
self.write("hell
浏览 0提问于2018-04-10得票数 0
我使用WebSocket中的示例，对安全的做了一个简单的Python (3.8)实现。这是在Windows 10计算机和连接到交换机/集线器的Ubuntu18.04.2 Linux机器之间。以下是粗略的服务器和客户端代码：
服务器：
# WSS (WS over TLS) server example, with a self-signed certificate
import asyncio
import pathlib
import ssl
import websockets
async def hello(websocket, path):
name = await websoc
浏览 2提问于2020-09-23得票数 0
回答已采纳
2回答
我试图制造一个不和谐的机器人，但我得到了以下奇怪的错误，它不能导入asyncio.Transport，虽然我可以正常使用它在这段代码之外。
守则：
import asyncio
import os
import discord
from dotenv import load_dotenv
错误信息：
Traceback (most recent call last):
File "dis.py", line 1, in <module>
import asyncio
File "C:\Users\A.Gawish\AppData\Local\
浏览 0提问于2019-12-20得票数 1
回答已采纳
我有一些使用asyncio并启动“普通”连接的python代码片段：
loop = asyncio.get_event_loop()
coro = loop.create_connection(lambda: MyCustomClassProtocol(loop), sock=client_socket)
loop.run_until_complete(coro)
关键是，一旦发生了一些交换，我的普通连接切换到tls连接。按照传统的方式，人们会这样做：
ssl_sock = ssl.wrap_socket(client_socket, do_handshake_on_connect=False
浏览 2提问于2015-06-15得票数 4
回答已采纳
我要把我的机器人从我那台破旧的笔记本电脑上移到一个合适的VPS上。我使用的是较老的Discord.py异步版本(0.16.0)，因为我在重写之前很久就开始了这方面的工作；而且我对Linux没有太多的经验，所以迁移到Windows Server似乎是谨慎的。我已经安装了所有相同的软件包(据我所知)，但在bot.run()行上，我在启动时总是收到一个错误：
ssl.SSLError: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed (_ssl.c:749)
这个错误发生在握手过程中，据我从堆栈跟踪可以看出，我并不知道这意味着什么
浏览 4提问于2019-08-17得票数 2
我正在尝试使用asyncio构建一个简单的类，但我遇到了错误 builtins.RuntimeError: Session is closed 我认为这不是与服务器有关，而是与我的代码架构有关。 代码如下： import aiohttp
import asyncio
class MordomusConnect:
def __init__(self, ip=None, port='8888'):
self._ip = ip
self._port = port
async def _getLoginSession(self)
浏览 280提问于2020-04-05得票数 1
回答已采纳
如果我在python中运行以下代码，就会得到一个错误。
import discord
from discord.ext import commands
TOKEN = "token"
client = commands.Bot(command_prefix = "rps/")
@client.event
async def on_ready():
print ('ready')
client.run("token")
错误：
追溯(最近一次调用)：文件"/Users/timothy/Library/Pyt
浏览 1提问于2018-10-06得票数 0
我的代码的简化版本如下所示：
def run_async(spawn_coro, timeout):
async def _read_print_line(process):
line = await process.stdout.readline()
line = line.decode('utf-8', errors='replace')
sys.stdout.write(line)
process = await spawn_coro
try:
while not p
浏览 9提问于2020-09-15得票数 2
我正在使用asyncio和aiohttp进行并发请求。我最近将Python升级到了3.8.0版本，在程序运行后我得到了一个RuntimeError: Event loop is closed。 import asyncio
import aiohttp
async def do_call(name, session):
async with session.get('https://www.google.be') as response:
await response.text()
return 'ok - {}'.f
浏览 149提问于2019-12-10得票数 5
回答已采纳
我正在寻找一种加载如下所示的TLS证书文件(ssl_cert_auth_params)的方法：
-----BEGIN CERTIFICATE-----
****************************************************************
****************************************************************
****************************************************************
*****************************
浏览 4提问于2021-05-28得票数 0
回答已采纳
1回答
F5均衡器和原始插座(纵横制)
、、、、
我正在尝试使用rawsocket作为使用autobahn-python客户端和crossbar服务器的传输模式(不工作，也不建立连接) DEBUG:file_uploader.spEm_PreFile:Logger Started in Debug mode
DEBUG:asyncio:Get address info dev4-dv.davinci-onsite.com:443, type=<SocketKind.SOCK_STREAM: 1>
DEBUG:asyncio:Getting address info dev4-dv.davinci-onsite.com:443,
浏览 42提问于2019-12-07得票数 0
我在虚拟盒上运行了ubuntu16.04(在mac上)，在aws ec2 ubuntu18.04上运行。我试图在aws.ec2上运行木星笔记本，并试图通过本地Ubuntu上的网页浏览器远程访问它。我可以访问远程ubuntu(aws.ec2)终端。在我遵循这个上的步骤之后
在步骤9中，我得到了以下错误。
我从头开始重新安装了3次(包括本地的ubuntu和aws ec2实例)，但到目前为止没有进展。
Last login: Thu Nov 1 06:34:07 2018 from 134.1****
ubuntu@ip-172-***:~$ export XDG_RUNTIME_DIR="
浏览 0提问于2018-11-01得票数 4
我正在尝试使用库，但我得到了RuntimeError: Event loop is closed。
这是我的代码和回溯。
代码
import asyncio
import asyncpraw
async def main():
reddit = asyncpraw.Reddit('praw_ini_name')
print('User is', await reddit.user.me())
await reddit.close()
asyncio.run(main())
回溯
User is python_user
Exceptio
浏览 4提问于2021-02-28得票数 3
回答已采纳
我正试着在Jupyter上运行justpy web应用程序，比如下面这个：
import justpy as jp
def hello_world():
wp = jp.WebPage()
d = jp.Div(text='Hello world!')
wp.add(d)
return wp
jp.justpy(hello_world)
但无论我是在Jupyter Notebook上运行还是在Jupyter Lab上运行，这都会产生错误：
----------------------------------------------------
浏览 4提问于2021-04-02得票数 1
2回答
我在Python中有一个通过aiosmtp接受(E)SMTP请求的代码，但是由于我在Debian 10上推送了这段代码，所以有一些以前没有出现的错误(而且我的代码没有更改)：
SSL:无共享密码()
SSL握手失败协议:传输：<_SelectorSocketTransport fd=11 read=polling write=>
SSLError: [SSL: NO_SHARED_CIPHER] no shared cipher (_ssl.c:1056)
File "asyncio/sslproto.py", line 625, in _on_hand
浏览 14提问于2019-10-05得票数 5
我尝试在mac Mojave 10.14上使用加密源python库。https://github.com/bmoscon/cryptofeed 下面的代码在windows上运行良好。 from cryptofeed.callback import BookCallback
from cryptofeed import FeedHandler
from cryptofeed.exchanges import Bitmex
from cryptofeed.defines import L2_BOOK, BID, ASK
import os, curses
rows=5
async def b
浏览 20提问于2019-12-14得票数 2
回答已采纳
在Python3.6.1中，在从asyncio.get_event_loop()获得的循环上调用loop.close()之后，可以创建新的循环吗？
我已经看过其他一些文章，它们提供了正确关闭循环的答案，以及如何使用task.cancel()，但我还没有能够使用这些示例中的任何一个，以便在第一个循环关闭后创建一个新的循环。我还尝试显式设置executor，然后调用executor.shutdown(wait=True)，但没有帮助。我还尝试了“del loop”，还有很多其他的东西。
文档表明，关闭一个事件循环是幂等的和不可逆的。这是否也意味着不能创建新的循环？
这里有一些简单的示例代码来演示这
浏览 0提问于2017-04-27得票数 5
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
