Python3の高速で信頼性の高い分散タスク処理ライブラリ「Dramatiq」のインストール

Python3の高速で信頼性の高い分散タスク処理ライブラリ「Dramatiq」のインストールについて解説しています。

「Dramatiq（https://dramatiq.io/,https://github.com/Bogdanp/dramatiq）」は、バックグラウンドでタスク処理ができるライブラリとなります。Dramatiqはシンプルで信頼性の高いものとなっています。

■Python
■Dramatiqをインストールする

■Python

今回のPythonのバージョンは、「3.8.5」を使用しています。（Windows10）（pythonランチャーでの確認）

■Dramatiqをインストールする

Dramatiqをインストールを行いますが、今回はpipを経由してインストールを行うので、まずWindowsのコマンドプロンプトを起動します。なお、Dramatiqのインストールする方法はいくつかありますが、今回は推奨されるメッセージブローカーである「RabbitMQ」と合わせてインストールしてみます。（https://dramatiq.io/installation.html）

pip install -U "dramatiq[rabbitmq, watch]"

起動後、上記のコマンドを入力し、Enterキーを押します。

なお、今回は、pythonランチャーを使用しており、Python Version 3.8.5にインストールを行うために、バージョンの切り替えを行います。

py -3.8 -m pip install -U "dramatiq[rabbitmq, watch]"

切り替えるために、上記のコマンドを入力し、Enterキーを押します。

Defaulting to user installation because normal site-packages is not writeable
Collecting dramatiq[rabbitmq,watch]
Downloading dramatiq-1.13.0-py3-none-any.whl (114 kB)
---------------------------------------- 114.2/114.2 kB 1.3 MB/s eta 0:00:00
Collecting prometheus-client>=0.2
Downloading prometheus_client-0.15.0-py3-none-any.whl (60 kB)
---------------------------------------- 60.1/60.1 kB 3.3 MB/s eta 0:00:00
Collecting pika<2.0,>=1.0
Downloading pika-1.3.1-py3-none-any.whl (155 kB)
---------------------------------------- 155.3/155.3 kB 3.1 MB/s eta 0:00:00
Collecting watchdog
Downloading watchdog-2.2.1-py3-none-win_amd64.whl (78 kB)
---------------------------------------- 79.0/79.0 kB 4.6 MB/s eta 0:00:00
Collecting watchdog-gevent
Downloading watchdog_gevent-0.1.1-py3-none-any.whl (3.7 kB)
Collecting gevent>=1.1
Downloading gevent-22.10.2-cp38-cp38-win_amd64.whl (1.5 MB)
---------------------------------------- 1.5/1.5 MB 2.9 MB/s eta 0:00:00
Collecting greenlet>=2.0.0
Downloading greenlet-2.0.1-cp38-cp38-win_amd64.whl (190 kB)
---------------------------------------- 190.7/190.7 kB 5.8 MB/s eta 0:00:00
Requirement already satisfied: zope.interface in c:\users\user_\appdata\roaming\python\python38\site-packages (from gevent>=1.1->watchdog-gevent->dramatiq[rabbitmq,watch]) (5.5.2)
Collecting zope.event
Downloading zope.event-4.6-py2.py3-none-any.whl (6.8 kB)
Requirement already satisfied: cffi>=1.12.2 in c:\users\user_\appdata\roaming\python\python38\site-packages (from gevent>=1.1->watchdog-gevent->dramatiq[rabbitmq,watch]) (1.15.1)
Requirement already satisfied: setuptools in c:\users\user_\appdata\roaming\python\python38\site-packages (from gevent>=1.1->watchdog-gevent->dramatiq[rabbitmq,watch]) (59.8.0)
Requirement already satisfied: pycparser in c:\users\user_\appdata\roaming\python\python38\site-packages (from cffi>=1.12.2->gevent>=1.1->watchdog-gevent->dramatiq[rabbitmq,watch]) (2.21)
Installing collected packages: zope.event, watchdog, prometheus-client, pika, greenlet, gevent, dramatiq, watchdog-gevent
Successfully installed dramatiq-1.13.0 gevent-22.10.2 greenlet-2.0.1 pika-1.3.1 prometheus-client-0.15.0 watchdog-2.2.1 watchdog-gevent-0.1.1 zope.event-4.6

Enterキーを押すと、インストールが開始され、上記のように「Successfully installed」と表示されます。これが表示されれば、dramatiqが正常にインストールされたことになります。

なお、今回はdramatiqのバージョン1.13.0をインストールしました。