Cassandra のカウンターを更新する必要がある Python で記述されたスクリプトがあります。カウンターを修正するバッチのように機能します。
スクリプトが行うことは次のとおりです。データベースにあるはずの実際の値を取得し、データベースに保持されている現在の値を取得し、値の差を計算し、最後に特定の行キーに挿入コマンドを送信して、差を渡してカウンターを更新します。
すべて正常に動作します。正しい値と差分を取得しましたが、挿入コマンドの後、行キーの値が期待どおりではありません。
Example:
Real Value = 35000
Current DB Value = 30000
Diff Value = 5000
diff=5000 を渡して挿入コマンドを送信したので、期待される新しい DB 値は 35000 になるはずです。そのような値になる可能性のある値と演算子の組み合わせはないため、意味がありません。
そして、スクリプトを再度実行すると、最終的に永続化された値は正しいです。後で再試行すると、最終的に保持された値が再び間違っているように見えます...
誰でもこれで私を助けることができますか? 同じスクリプトが正常に動作することもあれば、異常な値が持続することもあります。
ありがとうございました ！