2

次のスクリプトの平和は、デッドロックのためにエラーが発生します。

sqlQuery = """INSERT INTO gps_points (gps_track_segment_id, gps_unit_id, date, lat,  lng) SELECT MAX(gps_track_segments.id) AS gps_track_segment_id, %(gps_unit_id)s AS gps_unit_id, %(date)s AS date, %(lat)s AS lat, %(lng)s AS lng FROM gps_track_segments 
    INNER JOIN gps_tracks ON gps_track_segments.gps_track_id = gps_tracks.id WHERE gps_tracks.hash = %(track)s"""

from django.db import connection, transaction
cursor = connection.cursor()
success = cursor.execute(sqlQuery, point)
transaction.commit_unless_managed()

エラーログは次のことを示しています。

2012-08-28 12:37:58,051 - django.db.backends - DEBUG - (0.018) INSERT INTO gps_points (gps_track_segment_id, gps_unit_id, date, lat, lng) SELECT MAX(gps_track_segments.id) AS gps_track_segment_id, 121 AS gps_unit_id, '2012-08-28 12:37:56' AS date, 51361100 AS lat, 4983910 AS lng FROM gps_track_segments 
    INNER JOIN gps_tracks ON gps_track_segments.gps_track_id = gps_tracks.id WHERE gps_tracks.hash = '7f5d950564786e182e175fb5d8e1b937528f85cc1ddabbee0d53859fb603ede3'; args={'gps_unit_id': 121L, 'lat': 51361100, 'date': '2012-08-28 12:37:56', 'course': None, 'track': u'7f5d950564786e182e175fb5d8e1b937528f85cc1ddabbee0d53859fb603ede3', 'speed': '0.0', 'lng': 4983910, 'segment': 5, 'altitude': None, 'accuracy': None}
Exception in thread Thread-1:
Traceback (most recent call last):
  File "/usr/lib64/python2.6/threading.py", line 532, in __bootstrap_inner
self.run()
  File "/usr/lib64/python2.6/threading.py", line 484, in run
self.__target(*self.__args, **self.__kwargs)
  ...
  ...
  File "/tcpserver/gpslibs.py", line 75, in saveGpsPoint
success = cursor.execute(sqlQuery, point)
  File "/usr/lib/python2.6/site-packages/django/db/backends/util.py", line 40, in execute
return self.cursor.execute(sql, params)
  File "/usr/lib/python2.6/site-packages/django/db/backends/mysql/base.py", line 114, in execute
return self.cursor.execute(query, args)
  File "/usr/lib64/python2.6/site-packages/MySQLdb/cursors.py", line 173, in execute
self.errorhandler(self, exc, value)
  File "/usr/lib64/python2.6/site-packages/MySQLdb/connections.py", line 36, in defaulterrorhandler
raise errorclass, errorvalue
DatabaseError: (1213, 'Deadlock found when trying to get lock; try restarting transaction')

mysqlコマンドSHOWENGINEINNODB STATUSを使用すると、上記のクエリがphpWebサイトによって要求されたクエリと競合することがわかりました。問題は、php-requestがロールバックされることもあれば、INSERTがロールバックされることもあるということです。最後のケースでは、スクリプトがデッドロックエラーで停止します。関連するクエリを変更するのは非常に難しいためです。私は今、次の場合が好きです：

どういうわけか、デッドロックで失敗せず、再試行するDjango / Pythonスクリプトを作成できますか？phpリクエストが失敗したり、ロールバックが発生したりすることはあまり気にしません。使いやすさの観点から、それを処理するのは簡単です。バックエンドスクリプトが失敗するのは気になります。これは何よりも機能する必要があります

4

1 に答える 1

2

デッドロックで失敗せず、再試行するだけの Django/Python スクリプトを何とか作成できますか?

発生した例外をキャッチしDatabaseError、トランザクションを再度実行するロジックを実行できます (おそらく、行を挿入する前に最初にテーブルの書き込みロックを取得します)。

try:
    success = cursor.execute(sqlQuery, point)
except DatabaseError:
     # retry here

理想的には、再度呼び出すことができるメソッドでラップする必要があります。

于 2012-08-29T14:58:39.943 に答える