Есть ли решение для распределенных транзакций в Python или MySQLdb, например Java Transaction API (JTA)?
У меня возникла проблема при обработке данных в нескольких базах данных (возможно, в разных базах данных).
Как обеспечить согласованность данных?
Я знаю, что в Java есть Java Transaction API (JTA).
Как я могу это сделать Python?
Вы можете использовать операторы SQL для выполнения транзакции XA. Это не так красиво, как настоящий API, но работает. Я не знаю, есть ли TM (менеджеры транзакций) для Python, но вы можете написать свой собственный.
Также обратите внимание, что в Java не требуется использовать сервер приложений при использовании XA. Пример: http://bugs.mysql.com/file.php?id=22190&bug_id=75316
In [1]: import mysql.connector
In [2]: c = mysql.connector.connect(host='127.0.0.1',port=5705,user='msandbox',password='msandbox');
In [3]: cur = c.cursor();
In [4]: cur.execute("XA START 'py-xa-001'");
In [5]: cur.execute("INSERT INTO test.t1 VALUES(1)");
In [6]: cur.execute("XA RECOVER");
In [7]: print(cur.fetchone());
None
In [8]: cur.execute("XA END 'py-xa-001'");
In [9]: cur.execute("XA PREPARE 'py-xa-001'");
In [10]: cur.execute("XA RECOVER");
In [11]: print(cur.fetchone());
(1, 9, 0, u'py-xa-001')
In [12]: cur.execute("XA ROLLBACK 'py-xa-001'");
In [13]: cur.close()
Out[13]: True
In [14]: c.disconnect()
Я сам не использовал эту опцию, но при беглом взгляде кажется, что библиотека Transaction соответствует описанию того, что предлагает API транзакций Java. Он доступен для загрузки в pypi и задокументирован в ознакомиться с документацией
