ステイル読み取り

Stale ステイル読み取りは、TiDB に保存されているデータの履歴バージョンを読み取るために TiDB が適用するメカニズムです。このメカニズムを使用すると、特定の時間または指定された時間範囲内で対応する履歴データを読み取ることができるため、ストレージ ノード間のデータ レプリケーションによって発生するレイテンシーを節約できます。 Steal Read を使用している場合、TiDB はデータ読み取り用のレプリカをランダムに選択します。つまり、すべてのレプリカをデータ読み取りに使用できます。

実際には、 使用シナリオに基づいて TiDB で Stale ステイル読み取りを有効にすることが適切かどうかを慎重に検討してください。アプリケーションが非リアルタイム データの読み取りを許容できない場合は、 ステイル読み取り を有効にしないでください。

TiDB は、ステートメント レベル、トランザクション レベル、およびセッション レベルの 3 つのレベルの Stale ステイル読み取りを提供します。

序章

書店のアプリケーションでは、次の SQL ステートメントを使用して、最新の出版済み書籍とその価格を照会できます。

SELECT id, title, type, price FROM books ORDER BY published_at DESC LIMIT 5;

結果は次のとおりです。

+------------+------------------------------+-----------------------+--------+ | id | title | type | price | +------------+------------------------------+-----------------------+--------+ | 3181093216 | The Story of Droolius Caesar | Novel | 100.00 | | 1064253862 | Collin Rolfson | Education & Reference | 92.85 | | 1748583991 | The Documentary of cat | Magazine | 159.75 | | 893930596 | Myrl Hills | Education & Reference | 356.85 | | 3062833277 | Keven Wyman | Life | 477.91 | +------------+------------------------------+-----------------------+--------+ 5 rows in set (0.02 sec)

現時点 (2022-04-20 15:20:00) のリストでは、 The Story of Droolius Caesar の価格は 100.0 です。

同時に、売り手はその本が非常に人気があることを知り、次の SQL ステートメントを使用して本の価格を 150.0 に引き上げました。

UPDATE books SET price = 150 WHERE id = 3181093216;

結果は次のとおりです。

Query OK, 1 row affected (0.00 sec) Rows matched: 1 Changed: 1 Warnings: 0

最新の本のリストを照会すると、この本の価格が上昇したことがわかります。

+------------+------------------------------+-----------------------+--------+ | id | title | type | price | +------------+------------------------------+-----------------------+--------+ | 3181093216 | The Story of Droolius Caesar | Novel | 150.00 | | 1064253862 | Collin Rolfson | Education & Reference | 92.85 | | 1748583991 | The Documentary of cat | Magazine | 159.75 | | 893930596 | Myrl Hills | Education & Reference | 356.85 | | 3062833277 | Keven Wyman | Life | 477.91 | +------------+------------------------------+-----------------------+--------+ 5 rows in set (0.01 sec)

最新のデータを使用する必要がない場合は、古いデータを返す可能性があるステイル読み取り を使用してクエリを実行し、強力な整合性のある読み取り中のデータ レプリケーションによって生じるレイテンシー時間を回避できます。

Bookshop アプリケーションでは、書籍のリアルタイム価格は書籍リスト ページでは必要なく、書籍の詳細ページと注文ページでのみ必要であると仮定します。 ステイル読み取りを使用して、アプリケーション全体を改善できます。

ステートメント レベル

  • SQL
  • Java

特定の時間の前に書籍の価格を照会するには、上記のクエリ ステートメントにAS OF TIMESTAMP <datetime>句を追加します。

SELECT id, title, type, price FROM books AS OF TIMESTAMP '2022-04-20 15:20:00' ORDER BY published_at DESC LIMIT 5;

結果は次のとおりです。

+------------+------------------------------+-----------------------+--------+ | id | title | type | price | +------------+------------------------------+-----------------------+--------+ | 3181093216 | The Story of Droolius Caesar | Novel | 100.00 | | 1064253862 | Collin Rolfson | Education & Reference | 92.85 | | 1748583991 | The Documentary of cat | Magazine | 159.75 | | 893930596 | Myrl Hills | Education & Reference | 356.85 | | 3062833277 | Keven Wyman | Life | 477.91 | +------------+------------------------------+-----------------------+--------+ 5 rows in set (0.01 sec)

正確な時間を指定するだけでなく、次のことも指定できます。

  • AS OF TIMESTAMP NOW() - INTERVAL 10 SECONDは 10 秒前の最新データを問い合わせます。
  • AS OF TIMESTAMP TIDB_BOUNDED_STALENESS('2016-10-08 16:45:26', '2016-10-08 16:45:29')2016-10-08 16:45:262016-10-08 16:45:29の間の最新のデータをクエリします。
  • AS OF TIMESTAMP TIDB_BOUNDED_STALENESS(NOW() -INTERVAL 20 SECOND, NOW())は 20 秒以内に最新のデータをクエリします。

指定されたタイムスタンプまたは間隔は、現在の時刻より早すぎたり遅すぎたりすることはできないことに注意してください。

期限切れのデータは TiDB でガベージ コレクションによってリサイクルされ、データはクリアされる前に短期間保持されます。期間はGC ライフタイム (デフォルトは 10 分)と呼ばれます。 GC が開始されると、現在の時刻から期間を引いた値がGC セーフ ポイントとして使用されます。 GC セーフ ポイントの前にデータを読み込もうとすると、TiDB は次のエラーを報告します。

ERROR 9006 (HY000): GC life time is shorter than transaction duration...

指定されたタイムスタンプが将来の時刻である場合、TiDB は次のエラーを報告します。

ERROR 9006 (HY000): cannot set read timestamp to a future time.
public class BookDAO { // Omit some code... public List<Book> getTop5LatestBooks() throws SQLException { List<Book> books = new ArrayList<>(); try (Connection conn = ds.getConnection()) { Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(""" SELECT id, title, type, price FROM books ORDER BY published_at DESC LIMIT 5; """); while (rs.next()) { Book book = new Book(); book.setId(rs.getLong("id")); book.setTitle(rs.getString("title")); book.setType(rs.getString("type")); book.setPrice(rs.getDouble("price")); books.add(book); } } return books; } public void updateBookPriceByID(Long id, Double price) throws SQLException { try (Connection conn = ds.getConnection()) { PreparedStatement stmt = conn.prepareStatement(""" UPDATE books SET price = ? WHERE id = ?; """); stmt.setDouble(1, price); stmt.setLong(2, id); int affects = stmt.executeUpdate(); if (affects == 0) { throw new SQLException("Failed to update the book with id: " + id); } } } public List<Book> getTop5LatestBooksWithStaleRead(Integer seconds) throws SQLException { List<Book> books = new ArrayList<>(); try (Connection conn = ds.getConnection()) { PreparedStatement stmt = conn.prepareStatement(""" SELECT id, title, type, price FROM books AS OF TIMESTAMP NOW() - INTERVAL ? SECOND ORDER BY published_at DESC LIMIT 5; """); stmt.setInt(1, seconds); ResultSet rs = stmt.executeQuery(); while (rs.next()) { Book book = new Book(); book.setId(rs.getLong("id")); book.setTitle(rs.getString("title")); book.setType(rs.getString("type")); book.setPrice(rs.getDouble("price")); books.add(book); } } catch (SQLException e) { if ("HY000".equals(e.getSQLState()) && e.getErrorCode() == 1105) { System.out.println("WARN: cannot set read timestamp to a future time."); } else if ("HY000".equals(e.getSQLState()) && e.getErrorCode() == 9006) { System.out.println("WARN: GC life time is shorter than transaction duration."); } else { throw e; } } return books; } }
List<Book> top5LatestBooks = bookDAO.getTop5LatestBooks(); if (top5LatestBooks.size() > 0) { System.out.println("The latest book price (before update): " + top5LatestBooks.get(0).getPrice()); Book book = top5LatestBooks.get(0); bookDAO.updateBookPriceByID(book.getId(), book.price + 10); top5LatestBooks = bookDAO.getTop5LatestBooks(); System.out.println("The latest book price (after update): " + top5LatestBooks.get(0).getPrice()); // Use the stale read. top5LatestBooks = bookDAO.getTop5LatestBooksWithStaleRead(5); System.out.println("The latest book price (maybe stale): " + top5LatestBooks.get(0).getPrice()); // Try to stale read the data at the future time. bookDAO.getTop5LatestBooksWithStaleRead(-5); // Try to stale read the data before 20 minutes. bookDAO.getTop5LatestBooksWithStaleRead(20 * 60); }

次の結果は、 ステイル読み取りによって返された価格が更新前の値である 100.00 であることを示しています。

The latest book price (before update): 100.00 The latest book price (after update): 150.00 The latest book price (maybe stale): 100.00 WARN: cannot set read timestamp to a future time. WARN: GC life time is shorter than transaction duration.

取引レベル

START TRANSACTION READ ONLY AS OF TIMESTAMPステートメントを使用すると、履歴時間に基づいて読み取り専用トランザクションを開始できます。これにより、指定された履歴タイムスタンプから履歴データが読み取られます。

  • SQL
  • Java

例えば:

START TRANSACTION READ ONLY AS OF TIMESTAMP NOW() - INTERVAL 5 SECOND;

書籍の最新の価格を照会すると、 The Story of Droolius Caesarの価格がまだ更新前の値である 100.0 であることがわかります。

SELECT id, title, type, price FROM books ORDER BY published_at DESC LIMIT 5;

結果は次のとおりです。

+------------+------------------------------+-----------------------+--------+ | id | title | type | price | +------------+------------------------------+-----------------------+--------+ | 3181093216 | The Story of Droolius Caesar | Novel | 100.00 | | 1064253862 | Collin Rolfson | Education & Reference | 92.85 | | 1748583991 | The Documentary of cat | Magazine | 159.75 | | 893930596 | Myrl Hills | Education & Reference | 356.85 | | 3062833277 | Keven Wyman | Life | 477.91 | +------------+------------------------------+-----------------------+--------+ 5 rows in set (0.01 sec)

COMMIT;ステートメントのトランザクションがコミットされた後、最新のデータを読み取ることができます。

+------------+------------------------------+-----------------------+--------+ | id | title | type | price | +------------+------------------------------+-----------------------+--------+ | 3181093216 | The Story of Droolius Caesar | Novel | 150.00 | | 1064253862 | Collin Rolfson | Education & Reference | 92.85 | | 1748583991 | The Documentary of cat | Magazine | 159.75 | | 893930596 | Myrl Hills | Education & Reference | 356.85 | | 3062833277 | Keven Wyman | Life | 477.91 | +------------+------------------------------+-----------------------+--------+ 5 rows in set (0.01 sec)

ヘルパー メソッドとしてトランザクション レベルでステイル読み取りを有効にするコマンドをカプセル化する、トランザクションのヘルパー クラスを定義できます。

public static class StaleReadHelper { public static void startTxnWithStaleRead(Connection conn, Integer seconds) throws SQLException { conn.setAutoCommit(false); PreparedStatement stmt = conn.prepareStatement( "START TRANSACTION READ ONLY AS OF TIMESTAMP NOW() - INTERVAL ? SECOND;" ); stmt.setInt(1, seconds); stmt.execute(); } }

次に、 BookDAOクラスのトランザクションを通じてステイル読み取り機能を有効にするメソッドを定義します。クエリ ステートメントにAS OF TIMESTAMPを追加する代わりに、 メソッドを使用してクエリを実行します。

public class BookDAO { // Omit some code... public List<Book> getTop5LatestBooksWithTxnStaleRead(Integer seconds) throws SQLException { List<Book> books = new ArrayList<>(); try (Connection conn = ds.getConnection()) { // Start a read only transaction. TxnHelper.startTxnWithStaleRead(conn, seconds); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(""" SELECT id, title, type, price FROM books ORDER BY published_at DESC LIMIT 5; """); while (rs.next()) { Book book = new Book(); book.setId(rs.getLong("id")); book.setTitle(rs.getString("title")); book.setType(rs.getString("type")); book.setPrice(rs.getDouble("price")); books.add(book); } // Commit transaction. conn.commit(); } catch (SQLException e) { if ("HY000".equals(e.getSQLState()) && e.getErrorCode() == 1105) { System.out.println("WARN: cannot set read timestamp to a future time."); } else if ("HY000".equals(e.getSQLState()) && e.getErrorCode() == 9006) { System.out.println("WARN: GC life time is shorter than transaction duration."); } else { throw e; } } return books; } }
List<Book> top5LatestBooks = bookDAO.getTop5LatestBooks(); if (top5LatestBooks.size() > 0) { System.out.println("The latest book price (before update): " + top5LatestBooks.get(0).getPrice()); Book book = top5LatestBooks.get(0); bookDAO.updateBookPriceByID(book.getId(), book.price + 10); top5LatestBooks = bookDAO.getTop5LatestBooks(); System.out.println("The latest book price (after update): " + top5LatestBooks.get(0).getPrice()); // Use the stale read. top5LatestBooks = bookDAO.getTop5LatestBooksWithTxnStaleRead(5); System.out.println("The latest book price (maybe stale): " + top5LatestBooks.get(0).getPrice()); // After the stale read transaction is committed. top5LatestBooks = bookDAO.getTop5LatestBooks(); System.out.println("The latest book price (after the transaction commit): " + top5LatestBooks.get(0).getPrice()); }

結果は次のとおりです。

The latest book price (before update): 100.00 The latest book price (after update): 150.00 The latest book price (maybe stale): 100.00 The latest book price (after the transaction commit): 150

SET TRANSACTION READ ONLY AS OF TIMESTAMPステートメントを使用すると、指定された履歴時間に基づいて、開かれたトランザクションまたは次のトランザクションを読み取り専用トランザクションに設定できます。トランザクションは、提供された履歴時間に基づいて履歴データを読み取ります。

  • SQL
  • Java

たとえば、次のAS OF TIMESTAMPステートメントを使用して、進行中のトランザクションを読み取り専用モードに切り替え、5 秒前の履歴データを読み取ることができます。

SET TRANSACTION READ ONLY AS OF TIMESTAMP NOW() - INTERVAL 5 SECOND;

ヘルパー メソッドとしてトランザクション レベルでステイル読み取りを有効にするコマンドをカプセル化する、トランザクションのヘルパー クラスを定義できます。

public static class TxnHelper { public static void setTxnWithStaleRead(Connection conn, Integer seconds) throws SQLException { PreparedStatement stmt = conn.prepareStatement( "SET TRANSACTION READ ONLY AS OF TIMESTAMP NOW() - INTERVAL ? SECOND;" ); stmt.setInt(1, seconds); stmt.execute(); } }

次に、 BookDAOクラスのトランザクションを通じてステイル読み取り機能を有効にするメソッドを定義します。クエリ ステートメントにAS OF TIMESTAMPを追加する代わりに、 メソッドを使用してクエリを実行します。

public class BookDAO { // Omit some code... public List<Book> getTop5LatestBooksWithTxnStaleRead2(Integer seconds) throws SQLException { List<Book> books = new ArrayList<>(); try (Connection conn = ds.getConnection()) { StaleReadHelper.setTxnWithStaleRead(conn, seconds); // Start a read only transaction. conn.setAutoCommit(false); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(""" SELECT id, title, type, price FROM books ORDER BY published_at DESC LIMIT 5; """); while (rs.next()) { Book book = new Book(); book.setId(rs.getLong("id")); book.setTitle(rs.getString("title")); book.setType(rs.getString("type")); book.setPrice(rs.getDouble("price")); books.add(book); } // Commit transaction. conn.commit(); } catch (SQLException e) { if ("HY000".equals(e.getSQLState()) && e.getErrorCode() == 1105) { System.out.println("WARN: cannot set read timestamp to a future time."); } else if ("HY000".equals(e.getSQLState()) && e.getErrorCode() == 9006) { System.out.println("WARN: GC life time is shorter than transaction duration."); } else { throw e; } } return books; } }

セッションレベル

履歴データの読み取りをサポートするために、TiDB は v5.4 以降、新しいシステム変数tidb_read_stalenessを導入しました。これを使用して、現在のセッションが読み取ることができる履歴データの範囲を設定できます。データ型はintで、スコープはSESSIONです。

  • SQL
  • Java

セッションでステイル読み取りを有効にします。

SET @@tidb_read_staleness="-5";

たとえば、値が-5に設定され、TiKV に対応する履歴データがある場合、TiDB は 5 秒の時間範囲内でできるだけ新しいタイムスタンプを選択します。

セッションでステイル読み取りを無効にします。

set @@tidb_read_staleness="";
public static class StaleReadHelper{ public static void enableStaleReadOnSession(Connection conn, Integer seconds) throws SQLException { PreparedStatement stmt = conn.prepareStatement( "SET @@tidb_read_staleness= ?;" ); stmt.setString(1, String.format("-%d", seconds)); stmt.execute(); } public static void disableStaleReadOnSession(Connection conn) throws SQLException { PreparedStatement stmt = conn.prepareStatement( "SET @@tidb_read_staleness=\"\";" ); stmt.execute(); } }

続きを読む

Playground
新規
登録なしで TiDB の機能をワンストップでインタラクティブに体験できます。
製品
TiDB Cloud
TiDB
価格
PoC お問い合わせ
エコシステム
TiKV
TiFlash
OSS Insight
© 2024 PingCAP. All Rights Reserved.
Privacy Policy.