Python 3.8.5

pip 20.2.2

ModuleNotFoundError: No module named 'unicorn_fy.unicorn_fy'; 'unicorn_fy' is not a package

I've fixed this for  unicorn-binance-websocket-api already. This is the same issue. The module is packaged as if it was a python script

Traceback (most recent call last):
  File "userdata_stream.py", line 34, in print_stream_data_from_stream_buffer
    unicorn = UnicornFy.binance_com_websocket(oldest_stream_data_from_stream_buffer)
  File "/home/dennis/py-projects/binance_ws/venv/lib/python3.7/site-packages/unicorn_fy/unicorn_fy.py", line 125, in binance_com_websocket
    return UnicornFy.binance_websocket(stream_data_json, exchange="binance.com", show_deprecated_warning=False)
  File "/home/dennis/py-projects/binance_ws/venv/lib/python3.7/site-packages/unicorn_fy/unicorn_fy.py", line 246, in binance_websocket
    if stream_data['data']['e'] == 'aggTrade':
KeyError: 'data'

{"e":"ORDER_TRADE_UPDATE","T":1593708087377,"E":1593708087381,"o":{"s":"BTCUSDT","c":"u7AlA2t0ltH7fmyNOXon0j","S":"BUY","o":"MARKET","f":"GTC","q":"0.128","
p":"0","ap":"8958.98000","sp":"0","x":"TRADE","X":"FILLED","i":5520695062,"l":"0.016","z":"0.128","L":"8958.98","n":"0.05733747","N":"USDT","T":1593708087377
,"t":157239716,"b":"0","a":"0","m":false,"R":false,"wt":"CONTRACT_PRICE","ot":"MARKET","ps":"BOTH","cp":false,"rp":"0"}}

 File "unittest_unicorn_fy.py", line 211, in test_depth_futures
    self.assertEqual(str(self.unicorn_fy.binance_com_futures_websocket(data)), asserted_result)
AssertionError: "{'st[186 chars]77, 'asks': [['43900.54000000', '0.01080000'],[1446 chars]v']}" != "{'st[186 chars]77, 'bids': [['43903.04000000', '0.00000000'],[3496 chars]v']}"
Diff is 5429 characters long. Set self.maxDiff to None to see it.

Datetimeindex = msg["E"] / 1000
Datetimeindex = datetime.fromtimestamp(Datetimeindex).strftime('%Y-%m-%d %H:%M:%S')

Symbol = msg['s']

Interval_Type = msg['k']['i']

Open_Price = msg['k']['o']

Close_Price = msg['k']['c']

High_Price = msg['k']['h']

Low_Price = msg['k']['l']

Volume = msg['k']['v']

Quantity = msg['k']['q']

print("{}, {}, {}, {}, {}, {}, {}, {}, {}, {}".format(Data_Type, Datetimeindex, 
                                                      Symbol, Interval_Type, Open_Price, 
                                                      Close_Price, High_Price, Low_Price, Volume, 
                                                      Quantity), file = "insert file name variable here, flush=True)``

  File "/usr/lib/python3.7/threading.py", line 926, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.7/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "/home/jean/myriad/projects/pyenv/crypto/lib/python3.7/site-packages/unicorn_binance_websocket_api/unicorn_binance_websocket_api_manager.py", line 415, in _create_stream_thread
    loop.run_until_complete(socket.start_socket())
  File "/usr/lib/python3.7/asyncio/base_events.py", line 579, in run_until_complete
    return future.result()
  File "/home/jean/myriad/projects/pyenv/crypto/lib/python3.7/site-packages/unicorn_binance_websocket_api/unicorn_binance_websocket_api_socket.py", line 114, in start_socket
    received_stream_data = self.unicorn_fy.binance_com_websocket(received_stream_data_json)
  File "/home/jean/myriad/projects/pyenv/crypto/lib/python3.7/site-packages/unicorn_fy/unicorn_fy.py", line 85, in binance_com_websocket
    return UnicornFy.binance_websocket(stream_data_json, exchange="binance.com", show_deprecated_warning=False)
  File "/home/jean/myriad/projects/pyenv/crypto/lib/python3.7/site-packages/unicorn_fy/unicorn_fy.py", line 249, in binance_websocket
    if stream_data['data']['e'] == 'aggTrade':
KeyError: 'data'

binance_websocket_api_manager = BinanceWebSocketApiManager(exchange="binance.com")
	binance_websocket_api_manager.create_stream(['ticker'], symbols_to_look )

	while True:
		oldest_stream_data_from_stream_buffer = binance_websocket_api_manager.pop_stream_data_from_stream_buffer()
		if oldest_stream_data_from_stream_buffer:
			unicorn_fied_stream_data = UnicornFy.binance_com_websocket(oldest_stream_data_from_stream_buffer)
			symbol = unicorn_fied_stream_data['data'][0]['symbol']
			fields=[symbol,
					unicorn_fied_stream_data['data'][0]['event_time'],
					unicorn_fied_stream_data['data'][0]['price_change'],
					unicorn_fied_stream_data['data'][0]['price_change_percent'],
					unicorn_fied_stream_data['data'][0]['last_price'],
					unicorn_fied_stream_data['data'][0]['best_bid_price'],
					unicorn_fied_stream_data['data'][0]['best_ask_price'],
					unicorn_fied_stream_data['data'][0]['total_traded_base_asset_volume'],
					unicorn_fied_stream_data['data'][0]['total_traded_quote_asset_volume']]

			path = data_path + symbol + '.csv'
			with open(path, 'a') as f:
				writer = csv.writer(f)
				writer.writerow(fields)

from unicorn_binance_websocket_api.manager import BinanceWebSocketApiManager
import logging
import time
import threading
import os
from unicorn_fy.unicorn_fy import UnicornFy
from termcolor import colored, cprint
import traceback
from pydantic import BaseModel
import time
from functools import wraps


# create instances of BinanceWebSocketApiManager
binance_com_websocket_api_manager = BinanceWebSocketApiManager(exchange="binance.com-futures", output_default="UnicornFy",throw_exception_if_unrepairable=True)

# configure api key and secret for binance.com for Alice
alice_api_key = ""
alice_api_secret = ""
# create the userData streams
alice_stream_id = binance_com_websocket_api_manager.create_stream('arr', '!userData', stream_label="Alice",
                                                                  stream_buffer_name=True,
                                                                  api_key=alice_api_key, api_secret=alice_api_secret)


info_stream = binance_com_websocket_api_manager.get_stream_list()

print(alice_stream_id)
print('status',info_stream[alice_stream_id]['status'])
print('stop_request',info_stream[alice_stream_id]['stop_request'])#停止请求
print('crash_request',info_stream[alice_stream_id]['crash_request'])#崩溃请求
print('kill_request',info_stream[alice_stream_id]['kill_request'])#杀死请求
print('reconnects',info_stream[alice_stream_id]['reconnects'])#重连次数


# print(binance_com_websocket_api_manager.get_stream_statistic(alice_stream_id))

# 结果转成JSON


def str2json(result):
    return UnicornFy.binance_com_futures_websocket(result)

def getdate2(t):
    '''时间戳转换为时间'''
    t1 = float(t)/1000
    # print(timeStamp)
    t2 = time.localtime(t1)
    # print(timeArray)
    t3 = time.strftime("%Y-%m-%d %H:%M:%S", t2)
    # print(otherStyleTime)
    return t3

# # https://docs.python.org/3/library/logging.html#logging-levels
logging.basicConfig(level=logging.DEBUG,
                    filename=os.path.basename(__file__) + '.log',
                    format="{asctime} [{levelname:8}] {process} {thread} {module}: {message}",
                    style="{")




# Python线程退出条件有以下几种：
# 1、线程内的函数语句执行完毕，线程自动结束
# 2、线程内的函数抛出未处理的异常

def print_stream_buffer_data(binance_websocket_api_manager, stream_id):
    while True:
        #有停止请求，则返回True ，否则返回 'False'。
        try :
            if binance_websocket_api_manager.is_manager_stopping():
                print("遇到错误了，正常运行程序并退出程序")
                exit(0)
            oldest_stream_data_from_stream_buffer = binance_websocket_api_manager.pop_stream_data_from_stream_buffer(stream_id)
            if oldest_stream_data_from_stream_buffer is False:
                time.sleep(0.01)
                
            else:
                # print(oldest_stream_data_from_stream_buffer)
                #信号状态
                data = UnicornFy.binance_com_futures_websocket(oldest_stream_data_from_stream_buffer)
                event_type = data["event_type"]
                if event_type == "ORDER_TRADE_UPDATE":
                    #币种
                    symbol = data['symbol']
                    #方向
                    side = data['side']
                    #持仓方向
                    position_side = data['position_side']
                    #挂单价格
                    order_price = data['order_price']
                    #实际成交价格
                    order_avg_price = data['order_avg_price']
                    #挂单数量
                    order_quantity = data['order_quantity']
                    current_order_status = data['current_order_status']
                    current_execution_type =  data['current_execution_type']
                    transaction_time = getdate2( data['transaction_time'])
                    
                    last_executed_price = data['last_executed_price']
                    #交易编号 ex android_mJlmVJJhRdpoL2fnSAhB
                    client_order_id =  data['client_order_id']
                    #交易ID  ex 60952023909
                    order_id =  data['order_id']
                    #这个目前没用
                    trade_id = data['trade_id']
                    #下单为 LIMIT  挂单止盈为TAKE_PROFIT
                    order_type = data['order_type']
                    
                    trad_type = None 
                    if order_type == "LIMIT":
                        trad_type = "限价单"
                    elif order_type == "TAKE_PROFIT":
                        trad_type = "止盈止损单"
                    elif order_type == "MARKET":
                        trad_type = "市价单" 

                    
                    temp ={ 
                        "BUYLONG":"买入开多",
                        "BUYSHORT":"买入平空",
                        "SELLSHORT":"卖出开空",
                        "SELLLONG":"卖出平多",
                        'NEWNEW':"挂单未成交",
                        'CANCELEDCANCELED':"撤单",
                        'TRADEFILLED':"挂单已成交",
                        'EXPIREDEXPIRED':"订单已过期",
                        'TRADEPARTIALLY_FILLED':'部分成交'
                    }
                
                    side_away = temp[side+position_side]
                    acction = temp[current_execution_type + current_order_status]
                    cprint(f"订单状态：{acction}  信号状态：{event_type} 币种：{symbol} 下单动作：{side_away} 挂单价格：{order_price} 成交价格：{order_avg_price} 平仓价格：{last_executed_price} 挂单数量：{order_quantity} 时间：{transaction_time}",
                        'green', 'on_red')
                    
        except BaseException as e :
            print(e)
            
                    



# start a worker process to move the received stream_data from the stream_buffer to a print function
worker_thread = threading.Thread(target=print_stream_buffer_data, args=(binance_com_websocket_api_manager,
                                                                        alice_stream_id))


# get info about the new stream
# second_multi_stream_info = binance_com_websocket_api_manager.get_stream_info(alice_stream_id)
# print(second_multi_stream_info)
worker_thread.start()

def print_stream_data_from_stream_buffer(binance_websocket_api_manager):
    while True:
        if binance_websocket_api_manager.is_manager_stopping():
            exit(0)
        oldest_stream_data_from_stream_buffer = \
            binance_websocket_api_manager.pop_stream_data_from_stream_buffer()
        if oldest_stream_data_from_stream_buffer is not False:
            unicorn_fied_data = UnicornFy.binance_com_websocket(
                    oldest_stream_data_from_stream_buffer)
            print('Time: {} Symbol: {} Side: {} Price: {} Quantity: {} '
                'Status: {}'.format(unicorn_fied_data['event_time'],
                                    unicorn_fied_data['symbol'],
                                    unicorn_fied_data['side'],
                                    unicorn_fied_data['order_price'],
                                    unicorn_fied_data['order_quantity'],
                                    unicorn_fied_data['current_order_status']))
        else:
            time.sleep(0.01)

Time: 1600220588187 Symbol: ETHBTC Side: BUY Price: 0.03000000 Quantity: 0.02300000 Status: NEW
Exception in thread Thread-16:
Traceback (most recent call last):
  File "C:\ProgramData\Anaconda3\lib\threading.py", line 932, in _bootstrap_inner
    self.run()
  File "C:\ProgramData\Anaconda3\lib\threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "C:\Users\asus\Documents\Personal\Corporate\Python\red_robin\websockettest.py", line 23, in print_stream_data_from_stream_buffer
    unicorn_fied_data['symbol'],
KeyError: 'symbol'

ERROR:root:Detected unknown data stream format (type2) in module `unicorn_fy`: please report to https://github.com/oliver-zehentleitner/unicorn_fy/issues {'stream': '!miniTicker@arr', 'data': [{'e': '24hrMiniTicker', 'E': 1588516002804, 's': 'BTCUSDT', 'c': '8900.00000000', 'o': '8898.33000000', 'h': '9200.00000000', 'l': '8811.00000000', 'v': '88800.22015400', 'q': '798918007.17006880'}, ... ]} - list indices must be integers or slices, not str

from unicorn_binance_websocket_api.unicorn_binance_websocket_api_manager import BinanceWebSocketApiManager
from unicorn_fy.unicorn_fy import UnicornFy

binance_websocket_api_manager = BinanceWebSocketApiManager(exchange="binance.com")
binance_websocket_api_manager.create_stream(['!miniTicker'], [])

while True:
    oldest_stream_data_from_stream_buffer = binance_websocket_api_manager.pop_stream_data_from_stream_buffer()
    if oldest_stream_data_from_stream_buffer:
        unicorn_fied_stream_data = UnicornFy.binance_com_websocket(oldest_stream_data_from_stream_buffer)
        print(unicorn_fied_stream_data)

        elif stream_data['e'] == 'ORDER_TRADE_UPDATE':
            stream_data = {'data': stream_data}
        elif stream_data['e'] == 'ACCOUNT_UPDATE':
            stream_data = {'data': stream_data}

       elif stream_data['data']['e'] == 'ORDER_TRADE_UPDATE':
            print('这里是发现了订单推送')
            unicorn_fied_data = {'stream_type': 'ORDER_TRADE_UPDATE',
                                 'event_type': stream_data['data']['e'],
                                 'event_time': stream_data['data']['E'],
                                 'symbol': stream_data['data']['o']['s'], # 交易对
                                 'client_order_id': stream_data['data']['o']['c'], # 订单编号
                                 'side': stream_data['data']['o']['S'], # 有用,订单方向
                                 'order_type': stream_data['data']['o']['o'], # 订单类型
                                 'time_in_force': stream_data['data']['o']['f'], # 有效方式
                                 'order_quantity': stream_data['data']['o']['q'], # 订单原始数量
                                 'order_price': stream_data['data']['o']['p'],# 原始价格
                                 'order_avg_price': stream_data['data']['o']['ap'],# 平均价格
                                 'order_tj_price': stream_data['data']['o']['sp'],# 条件订单触发价格，对追踪止损单无效
                                 'current_execution_type': stream_data['data']['o']['x'],# 本次事件的具体执行类型
                                 'current_order_status': stream_data['data']['o']['X'], # 订单的当前状态
                                 'order_id': stream_data['data']['o']['i'],# 订单ID
                                 'last_executed_quantity': stream_data['data']['o']['l'],# 订单末次成交量
                                 'cumulative_filled_quantity': stream_data['data']['o']['z'],# 订单累计已成交量
                                 'last_executed_price': stream_data['data']['o']['L'],# 订单末次成交价格
                                 # 'commission_amount': stream_data['data']['o']['n'],# 手续费数量
                                 # 'commission_asset': stream_data['data']['o']['N'],# 手续费资产类型
                                 'transaction_time': stream_data['data']['o']['T'],# 成交时间
                                 'trade_id': stream_data['data']['o']['t'], # 成交ID
                                 'net_pay': stream_data['data']['o']['b'], # 买单净值
                                 'net_selling_order_value': stream_data['data']['o']['a'],# 卖单净值
                                 'is_trade_maker_side': stream_data['data']['o']['m'], # 该成交是作为挂单成交吗
                                 'reduceOnly': stream_data['data']['o']['R'],# 是否是只减仓单
                                 'trigger_price_type': stream_data['data']['o']['wt'], # 触发价类型
                                 'order_price_type': stream_data['data']['o']['ot'],# 原始定单类型
                                 'positionSide': stream_data['data']['o']['ps'],
                                 # 'cumulative_quote_asset_transacted_quantity': stream_data['data']['cp'],
                                 # 'cumulative_quote_asset_transacted_quantity': stream_data['data']['AP'],
                                 # 'cumulative_quote_asset_transacted_quantity': stream_data['data']['cr'],
                                 'order_profit_loss': stream_data['data']['o']['rp']} #该交易实现盈亏

Python 3.8.5

pip 20.1.1

Traceback (most recent call last):
  File "/Users/bschwartz/.pyenv/versions/3.8.5/lib/python3.8/threading.py", line 932, in _bootstrap_inner
    self.run()
  File "/Users/bschwartz/.pyenv/versions/3.8.5/lib/python3.8/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "./project/exchange_account.py", line 23, in print_stream_data_from_stream_buffer
    stream_data = UnicornFy.binance_com_websocket(received_stream_data_json)
  File "/.../venv/lib/python3.8/site-packages/unicorn_fy/unicorn_fy.py", line 125, in binance_com_websocket
    return UnicornFy.binance_websocket(stream_data_json, exchange="binance.com", show_deprecated_warning=False)
  File "/.../venv/lib/python3.8/site-packages/unicorn_fy/unicorn_fy.py", line 246, in binance_websocket
    if stream_data['data']['e'] == 'aggTrade':
KeyError: 'data'

elif stream_data['e'] == 'outboundAccountPosition':
    stream_data = {'data': stream_data}

elif stream_data['data']['e'] == 'outboundAccountPosition':
    unicorn_fied_data = {'stream_type': '!userData@arr',
                            'event_type': stream_data['data']['e'],
                            'event_time': stream_data['data']['E'],
                            'last_update_time': stream_data['data']['u'],
                            'balances': []}
    for item in stream_data['data']['B']:
        new_item = {'asset': item['a'],
                    'free': item['f'],
                    'locked': item['l']}
        unicorn_fied_data['balances'] += [new_item]

Python 3.8.7

pip 21.0.1

ubwa_com_im.create_stream(
                "arr",
                "!userData",
                symbols="BTCUSDT",
                output="UnicornFy",
                api_key=binance_api_key,
                api_secret=binance_api_secret,
                stream_label="im BTCUSDT"
)

unicorn_stream                | 2021-03-16 20:21:58,309 - DEBUG |client - received solicited pong: 60806399
unicorn_stream                | 2021-03-16 20:22:10,470 - DEBUG |client - event = data_received(<72 bytes>)
unicorn_stream                | 2021-03-16 20:22:10,470 - DEBUG |client - event = data_received(<97 bytes>)
unicorn_stream                | 2021-03-16 20:22:10,481 - DEBUG |client < Frame(fin=True, opcode=1, data=b'{"e":"balanceUpdate","E":1615926131286,"a":"USDT","d":"1.00000000","T":1615926131285}', rsv1=False, rsv2=False, rsv3=False)
unicorn_stream                | 2021-03-16 20:22:10,491 - DEBUG |client < Frame(fin=True, opcode=1, data=b'{"e":"outboundAccountPosition","E":1615926131286,"u":1615926131285,"B":[{"a":"USDT","f":"1.00000000","l":"0.00000000"}]}', rsv1=False, rsv2=False, rsv3=False)
unicorn_stream                | 2021-03-16 20:22:10,622 - DEBUG |UnicornFy->binance_websocket({"e":"balanceUpdate","E":1615926131286,"a":"USDT","d":"1.00000000","T":1615926131285})
unicorn_stream                | 2021-03-16 20:22:10,627 - ERROR |BinanceWebSocketApiSocket.start_socket(d4b1ac8c-f4c3-4f4a-b6a7-e67bb04ad856, ['arr'], ['!userData']) - Exception General Exception - error_msg: 'data'
unicorn_stream                | 2021-03-16 20:22:10,632 - CRITICAL |BinanceWebSocketApiManager.stream_is_crashing(d4b1ac8c-f4c3-4f4a-b6a7-e67bb04ad856)
unicorn_stream                | 2021-03-16 20:22:10,638 - DEBUG |client - state = CLOSING
unicorn_stream                | 2021-03-16 20:22:10,643 - DEBUG |client > Frame(fin=True, opcode=8, data=b'\x03\xe8', rsv1=False, rsv2=False, rsv3=False)
unicorn_stream                | 2021-03-16 20:22:10,721 - INFO |BinanceWebSocketApiManager.kill_stream(d4b1ac8c-f4c3-4f4a-b6a7-e67bb04ad856)
unicorn_stream                | 2021-03-16 20:22:10,726 - INFO |BinanceWebSocketApiManager._restart_stream(d4b1ac8c-f4c3-4f4a-b6a7-e67bb04ad856, ['arr'], ['!userData'])
unicorn_stream                | 2021-03-16 20:22:10,737 - DEBUG |Using selector: EpollSelector

        try:
            if stream_data['e'] == 'outboundAccountInfo':
                stream_data = {'data': stream_data}
            elif stream_data['e'] == 'executionReport':
                stream_data = {'data': stream_data}
            elif stream_data['e'] == 'outboundAccountPosition':
                stream_data = {'data': stream_data}
            elif stream_data['e'] == 'listStatus':
                stream_data = {'data': stream_data}
        except KeyError:
            pass

Include here the response of 'python --version' or 'python3 --version'
Python 3.9.7

Include here the response of 'pip --version' or 'pip3 --version'
pip 21.2.4

def print_stream_buffer_data(binance_websocket_api_manager, stream_id):
    while True:
        if binance_websocket_api_manager.is_manager_stopping():
            exit(0)
        oldest_stream_data_from_stream_buffer = binance_websocket_api_manager.pop_stream_data_from_stream_buffer(
            stream_id)
        if oldest_stream_data_from_stream_buffer is False:
            time.sleep(0.01)
        else:
            order = UnicornFy.binance_com_futures_websocket(oldest_stream_data_from_stream_buffer) # <--- ERROR HERE
            if order.get('stream_type') == "ACCOUNT_CONFIG_UPDATE":
                # PROCESS DATA
            if order.get("stream_type") == "ORDER_TRADE_UPDATE":
                # PROCESS DATA