Pythonは動的にmysqlから行を選択します

Question

私はテーブルaddressを持っています。このテーブルは常に新しい行の挿入、appox 1行/秒を取得しています。それをprocess1と呼ぶことができます。

並行して、私は今までprocess1経由でSELECT * from addressの結果を繰り返し処理する必要があります。これはProcess2です。 Process1が最後に達した場合に新しい行を挿入するのを待つ必要があります。つまり、処理する行がもう1つもありません（反復）がaddressにあります。

処理1と処理2の両方が非常に長くなります。数時間または多分数日。

process2はどのように見えるのですか？

Answer 1

TIMESTAMP列を追加し、最後に処理されたタイムスタンプよりも新しいタイムスタンプを持つ行を選択します。