問題タブ [rethinkdb-python]

rethinkdb テーブルに以下の json 行があります。

これらの sid の et 値が入力値以上である sk フィールドをフィルタリングしようとしています。

以下のコードを試しましたが、動作しません

sk フィールドには最大 10 行を含めることができることに注意してください

フィルタリング後、['wc'] の結果データセットにもフィルターを適用したい (ge の場合)

私は何が欠けていますか？

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

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

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

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

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

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

rethinkdb クラスターから取得した行には、タイムゾーン付きの日付オブジェクトが含まれています。以下にその例を示します。

それらを特定の形式に文字列化しようとしています:

そしてそれはにつながる

どうすればこれを克服できますか？

私はこの例に広く従うアプリケーションを書いています。

次のような POST リクエストを送信すると:

curl http://localhost:5000/todos -d "data=Remember the milk" -X POST

RethinkDB から次のエラーが表示されます。

rethinkdb/ast.py", line 118, in run return c._start(self, **global_optargs) AttributeError: 'function' object has no attribute '_start'

誰もこの種のものに遭遇したことがありますか？Python 3.5.0 と Flask 0.10.1 で RethinkDB 2.2.2 を使用しています。

ありがとう、

アーロ

を使用してコンパイルしpyinstaller -F ./parser.specます。
次に、プログラムを実行する./dist/parserと、次のエラーが発生します。

フックファイルを作ってみたのですが、正直なところ何をやっているのかよくわからない感じです。

rethinkdb入っていますが、何が間違っているのかを示すエラーは表示さhiddenimportsれpyparserません。