DataStore の wait メソッドが変更されたデータを返す実装 #77
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Signed-off-by: MtkN1 <51289448+MtkN1@users.noreply.github.com>
MtkN1
reviewed
Jul 23, 2021
There was a problem hiding this comment.
内容確認しました。
waitメソッドのeventを利用してinsert/update/deleteから取得できるようにするロジックはとても巧妙ですね！
しかし以下(FTXDataStore)のように ** forループでinsertメソッドを呼ぶパターン ** があるため元の実装のままだとループの最後の1アイテムしか取得できません。
https://github.com/MtkN1/pybotters/blob/2f8504fa798ebddacda9ae13edafa56816bffeea/pybotters/models/ftx.py#L109-L115
これを解決したコードを直接コミットさせて頂きました。
|
実環境のテストコード async def main():
async with pybotters.Client() as client:
store = pybotters.FTXDataStore()
ws = await client.ws_connect(
'wss://ftx.com/ws/',
send_json={'op': 'subscribe', 'channel': 'trades', 'market': 'BTC-PERP'},
hdlr_json=store.onmessage
)
while True:
ret = await store.trades.wait()
print(ret) |
|
実装自体はこれで問題ないのですが、設計上懸念をしています。
果たしてこの仕様でいいのか/むしろそうあるべきなのか悩ましいです。 |
|
こちらマージが遅くなって申し訳ないです。 |
Merged
MtkN1
added a commit
that referenced
this pull request
Aug 15, 2021
✨v0.6.0リリース ## Issues ✅ 対応取引所の追加(Phemex、Coincheck) #52 ✅ GMO コインの DataStore を実装する #60 ✅ リリース表記をPreview版にする #73 ✅ FTXDataStore の orders チャネルにおける close されたオーダーの取り扱いについて #75 ✅ DataStoreInterfaceのクラス名を変更する #79 ## Pull requests ✅ GMO コイン用の DataStore を一部実装する #74 ✅ DataStore のレコード削除メソッドのサンプル実装 #76 ✅ DataStore の wait メソッドが変更されたデータを返す実装 #77 ✅ Sphinxのドキュメントを追加 #78
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
#75 の storewait() が変更されたデータを返す場合の簡単な実装です。
以下のメソッドの引数 data に渡された値を store.wait() が返します。
実際に変更されたデータが返されるわけではないことに注意してください。
get や find のようなクエリによる絞り込み機能は実装していません。