неожиданная таблица блокировок при использовании py mysql для чтения обновляемой таблицы в реальном времени - PullRequest
Новая
       39

неожиданная таблица блокировок при использовании py mysql для чтения обновляемой таблицы в реальном времени

0 голосов
/ 21 июня 2020

Я недавно использовал этот код для чтения таблицы в SQL. "tickersinfo" - это таблица, обновляемая в реальном времени, частота обновления которой составляет 3 минуты. Каждый раз, когда я читаю эту таблицу, эта таблица будет заблокирована. И после того, как я использую con.close(), чтобы закрыть это соединение, оно автоматически разблокируется. Может кто-нибудь сказать мне, почему?

Кроме того, эта программа не блокирует "filldetails". Я запутался. Они используют тот же код для чтения, но почему filldetails безопасно? 

con = pymysql.connect(host = "xxx",user = 'xxx',password = 'xxx',database = 'xxx')

price_cut = pd.read_sql("SELECT * FROM tickersinfo", con)
price_cut['mid_price'] = (price_cut['bid']+price_cut['ask'])/2
    
fill_details = pd.read_sql("SELECT * FROM filldetails", con)
fill_details['realized_qty'] = fill_details['qty'] - fill_details['left_qty']
fill_details['side'] = fill_details['side'].apply(lambda x: 1 if x=='BUY' else -1)
...