# オプション異常変動プッシュ

class OptionEventHandlerBase(RspHandlerBase)

説明

オプション異常変動プッシュを受信します。設定した異常変動アラートがトリガーされると、サーバーから異常変動情報がプッシュされます。事前に set_option_event_alert でアラート条件を設定し、handler でコールバックを登録する必要があります。ユーザーは OptionEventHandlerBase を継承し、on_recv_rsp メソッドをオーバーライドしてプッシュを受信します。

パラメータ

on_recv_rsp コールバックは (ret_code, content) を返します。content は dict：

パラメータ	型	説明
owner_code	str	原資産コード（例: 'US.TSLA'）
option_code	str	オプション契約コード（例: 'US.TSLA250620C250'）
message	str	プッシュメッセージテキスト

Example

from moomoo import *

class OptionEventHandler(OptionEventHandlerBase):
    def on_recv_rsp(self, rsp_pb):
        ret_code, content = super(OptionEventHandler, self).on_recv_rsp(rsp_pb)
        if ret_code != RET_OK:
            print("OptionEvent error:", content)
            return RET_ERROR, content

        print("オプション異常変動プッシュを受信:")
        print("  原資産:", content['owner_code'])
        print("  オプション:", content['option_code'])
        print("  メッセージ:", content['message'])
        return RET_OK, content

quote_ctx = OpenQuoteContext(host='127.0.0.1', port=11111)

# オプション異常変動プッシュハンドラーを登録
quote_ctx.set_handler(OptionEventHandler())

# set_option_event_alert でアラート条件を設定する必要があります。設定後にプッシュが有効になります
item = OptionEventAlertItem(
    option_market=OptionMarket.US_SECURITY,
    option_type=OptionType.CALL,
    order_type_list=[AlertOrderType.SWEEP],
    size_range_min=100,
)
ret, data = quote_ctx.set_option_event_alert(AlertOpType.ADD, item)
if ret == RET_OK:
    print('アラート設定成功、プッシュ待機中...')
else:
    print('設定失敗:', data)

import time
try:
    while True:
        time.sleep(1)
except KeyboardInterrupt:
    pass

quote_ctx.close()

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

Output

オプション異常変動プッシュを受信:
  原資産: US.TSLA
  オプション: US.TSLA250620C250
  メッセージ: TSLA $250 Call 06/20 大口スイープ 500枚 約定価格$12.50

1
2
3
4

← 異常取引アラート設定ゼロDTEオプションスクリーナー →

# オプション異常変動プッシュ

# Qot_UpdateOptionEvent.proto

# Qot_UpdateOptionEvent.proto