快捷導(dǎo)航

Python使用kombu連接信息中包含#號(hào)問(wèn)題排查方式

更新時(shí)間：2024年12月24日 09:31:39 作者：Chengdu.S

文章描述了在部署Python項(xiàng)目到生產(chǎn)環(huán)境時(shí)遇到的一個(gè)錯(cuò)誤,即端口號(hào)無(wú)法正確轉(zhuǎn)換為整數(shù)值,該錯(cuò)誤在測(cè)試環(huán)境和本地調(diào)試中沒(méi)有出現(xiàn),但在生產(chǎn)環(huán)境中才出現(xiàn),通過(guò)分析錯(cuò)誤信息和代碼,作者發(fā)現(xiàn)問(wèn)題出在URL解析過(guò)程中,特別是在處理包含特殊字符（如#號(hào)）的URL時(shí)

版本信息

框架	版本
python	3.11.7
kombu	5.3.4

環(huán)境搭建

python 虛擬環(huán)境

Python 虛擬環(huán)境（Virtual Environment）是一個(gè)隔離的 Python 解釋器環(huán)境，它允許你為每個(gè) Python 項(xiàng)目安裝其特定的依賴包，而不會(huì)干擾到全局 Python 環(huán)境或其他項(xiàng)目。

這樣，你可以確保每個(gè)項(xiàng)目都有其獨(dú)立的、一致的依賴環(huán)境，避免了版本沖突和依賴混亂的問(wèn)題。

Python 中有幾個(gè)流行的工具用于創(chuàng)建和管理虛擬環(huán)境，其中最常用的是 venv 和 virtualenv

venv 創(chuàng)建 python 虛擬環(huán)境

python -m venv .venv

執(zhí)行該命令之后，會(huì)創(chuàng)建一個(gè)虛擬的環(huán)境，產(chǎn)生 .venv文件夾，目錄結(jié)構(gòu)如下

激活虛擬環(huán)境

.venv\Scripts\activate

激活虛擬環(huán)境之后，文件夾前面會(huì)有括號(hào)顯示虛擬環(huán)境的名稱

退出虛擬環(huán)境

deactivate

虛擬環(huán)境下查看python、pip版本

查詢pip 配置信息

(.venv) F:\Python\mq>pip config list
global.index-url='http://mirrors.aliyun.com/pypi/simple/'
install.trusted-host='mirrors.aliyun.com'

安裝依賴

編寫 requirements.txt

kombu==5.3.4

在虛擬環(huán)境里面安裝依賴

pip install -r requirements.txt

問(wèn)題復(fù)現(xiàn)以及問(wèn)題排查

1.消息發(fā)布端 hello_publisher.py

from __future__ import annotations

import datetime

from kombu import Connection

with Connection('amqp://guest:guest#2024@localhost:5672//') as conn:
    simple_queue = conn.SimpleQueue('simple_queue')
    message = f'helloworld, sent at {datetime.datetime.today()}'
    simple_queue.put(message)
    print(f'Sent: {message}')
    simple_queue.close()

2.在虛擬環(huán)境運(yùn)行代碼

出現(xiàn)如下報(bào)錯(cuò)信息

(.venv) F:\Python\mq>python hello_publisher.py
Traceback (most recent call last):
File "F:\Python\mq\hello_publisher.py", line 7, in <module>
with Connection('amqp://guest:guest#2024@localhost:5672//') as conn:
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "F:\Python\mq\.venv\Lib\site-packages\kombu\connection.py", line 203, in __init__
url_params = parse_url(hostname)
^^^^^^^^^^^^^^^^^^^
File "F:\Python\mq\.venv\Lib\site-packages\kombu\utils\url.py", line 38, in parse_url
scheme, host, port, user, password, path, query = _parse_url(url)
^^^^^^^^^^^^^^^
File "F:\Python\mq\.venv\Lib\site-packages\kombu\utils\url.py", line 70, in url_to_parts
parts.port,
^^^^^^^^^^
File "E:\Anaconda\Lib\urllib\parse.py", line 182, in port
raise ValueError(f"Port could not be cast to integer value as {port!r}")
ValueError: Port could not be cast to integer value as 'guest'

看到報(bào)錯(cuò)的堆棧信息，首先定位到代碼行

File "F:\Python\mq\.venv\Lib\site-packages\kombu\utils\url.py", line 70

在此處加一個(gè)斷點(diǎn)，調(diào)試一下（生產(chǎn)服務(wù)不能調(diào)試就print輸出一下信息）

3.調(diào)試出問(wèn)題的代碼

報(bào)錯(cuò)的代碼方法如下

def url_to_parts(url):
    # type: (str) -> urlparts
    """Parse URL into :class:`urlparts` tuple of components."""
    scheme = urlparse(url).scheme
    schemeless = url[len(scheme) + 3:]
    # parse with HTTP URL semantics
    parts = urlparse('http://' + schemeless)
    path = parts.path or ''
    path = path[1:] if path and path[0] == '/' else path
    return urlparts(
        scheme,
        unquote(parts.hostname or '') or None,
        parts.port,
        unquote(parts.username or '') or None,
        unquote(parts.password or '') or None,
        unquote(path or '') or None,
        dict(parse_qsl(parts.query)),
    )

parts.port 獲取的值從 urlparse 方法中解析出來(lái)的