問題タブ [aiohttp]

クライアント/サーバーを含む比較的新しい Python 3 aiohttpライブラリがあります。ORMは含まれていますか？そうでない場合 - サードパーティの ORM で使用できますか? 不可能な場合 - どのような目的で使用できますか? ORM なしではアプリを作成できなかったという意味ではありませんが、Python フレームワークの大きな無駄が ORM をサポートしており、開発者はそのようなスタイルのプログラミングに慣れています。

Asyncio と aiohttp ライブラリを使用して一連のリクエスト (~1000) を作成しようとしていますが、多くの情報が見つからないという問題が発生しています。

このコードを 10 個の URL で実行すると、問題なく動作します。100以上のURLで実行すると、壊れてRuntimeError: Event loop is closedエラーが発生します。

スタック トレースはここにあります。

私はこれについて数時間頭を悩ませてきたので、どんな助けや洞察も大歓迎です。明らかに、これはまだ開いているはずのイベントループが閉じられたことを示唆していますが、それがどのように可能かわかりません。

aiohttpライブラリで関数の代わりにクラスベースのハンドラーを使用する正しいアプローチは何ですか? 私はDjangoでハンドラーをクラスとして記述することに慣れているので、 aiohttpで正しく行う方法を知りたいですか?

memcached を使用して aiohttp から関数をキャッシュしようとしています。デコレータとしてやりたいキャッシング。デコレータを呼び出す例は次のようになります。

キャッシュを扱う関数デコレータは次のようになります。

しかし、コンソールにエラーが表示されます:

私が質問を理解する限り：

可能な場合は応答をシリアライズ/デシリアライズする方法、不可能な場合は結果をキャッシュするために何をすべきか - いくつかの回避策がありますか?

作成したサーバーに多くの Web ソケット接続を行うプログラムを作成しようとしています。

問題は、すべてのクライアントが次々にジョブを実行することです。

を使用しようとしましasyncio.waitたが、すべてのクライアントが一緒に起動します。それらを徐々に作成し、それぞれが作成されたらすぐにサーバーに接続したいと思います。同時に、新しいクライアントを作成し続けます。

これを達成するには、どのようなアプローチを適用する必要がありますか?

ここでは、他の Web API ソースからデータを収集しようとしています。しかし、4〜5個のタスクfetch_pageを並行して実行しています。

「リクエストのサービス中にワーカーがクラッシュしました」というメッセージが表示されます

この問題から抜け出す方法を教えてください。

また、aiohttp.post リクエストからの応答で大量のデータを受信して​​いるため、write.write メソッドがクライアント側にデータを書き込めないことがあります。

2 つのハンドラーを持つ単純な aiohttp-server があります。async forまず、ループ内でいくつかの計算を行います。2 つ目は、テキスト応答を返すだけです。not_so_long_operation再帰的な実装が最も遅く、約 1 秒かかる 30 番目のフィボナッチ数を返します。

/フェッチしてから を取得しようとすると/lol/、最初のものが終了したときにのみ、2 番目の応答が返されます。
私は何を間違っていますか? また、反復ごとにインデックス ハンドラーが ioloop を解放する方法を教えてください。

別の Web API から一部のコンテンツをダウンロードするために aiohttp get リクエストを使用していますが、受信しています:

以下は、私が送信しようとしているデータです。

それを解決する方法は？

私は2つの方法でそれを試しました：

同時に、次を使用してデータを取得できます。

しかし、非同期の実装が必要です。

また、非同期の http リクエストを作成するimport requests代わりにライブラリを使用できる場合は、いくつかの方法を提案してくださいimport aiohttp。多くの場合、aiohttp の投稿と取得のリクエストは機能しませんが、同じことが requests.get と投稿のリクエストで機能するためです。

rethinkdb .changes() 機能を使用して、いくつかのメッセージをユーザーにプッシュしたいと思います。メッセージは、ユーザーからの要求なしで送信する必要があります。

aiohttp と websockets で rethinkdb を使用しています。使い方：

1. ユーザーがメッセージを送信
2. サーバーはそれをrethinkdbに入れます
3. 必要なもの: 追加のループでは rethinkdb.changes関数を使用して、接続されているユーザーに更新を送信します

これは私がアプリケーションを開始する方法です:

にはwshandler、着信メッセージを処理するループがあります。

開いている接続の同じプールにメッセージを送信する 2 番目のループを作成する方法は? スレッドセーフにする方法は？

私は非同期プログラミングの初心者です。Web ページのステータスをチェックするために使用されるスクリプトを作成しようとしています。そしてもちろん、私はそれを非同期にしたいと思います。私のスニペット:

しかし、次のエラーが表示されます:Task was destroyed but it is pending! 誰かが私が間違えた場所を教えてもらえますか?