Tair (Redis® OSS-Compatible):キーの一括削除

(推奨) SCAN と UNLINK を使用

このメソッドは、特定のパターンに一致するキーを繰り返しスキャンして削除します。

1. 次のコードを scan_and_unlink.py スクリプトとして保存します:

   import redis
   import sys
   
   def main(argv):
       if len(argv) < 4:
           print("Usage: python scan_and_del.py host port password match")
           sys.exit(-1)
   
       host = argv[1]
       port = argv[2]
       password = argv[3]
       match = argv[4]
       print("host: %s, port: %s, password: %s, match: %s\n" % (host, port, password, match))
   
       redis_cli = redis.StrictRedis(host=host, port=port, password=password)
       cursor = 0
       rnd = 1
   
       while rnd == 1 or cursor != 0:
           result = redis_cli.scan(cursor=cursor, match=match, count=1000)
           ret_cursor = result[0]
           ret_keys = result[1]
           num_keys = len(ret_keys)
           print("Deleted %d keys in round %d. Cursor: %d" % (num_keys, rnd, ret_cursor))
           if 0 != num_keys:
               ret_unlink = redis_cli.unlink(*ret_keys)
               print("unlink returned: %d, keys unlinked: %s" % (ret_unlink, ret_keys))
           cursor = ret_cursor
           rnd += 1
           print("")
   
   if __name__ == '__main__':
       main(sys.argv)

2. 次のコマンドを実行してスクリプトを実行します:

   python scan_and_unlink.py <host> <port> <password> "<key>" 

   パラメーター:

   • host: Redis インスタンスのエンドポイント。

   • port: Redis インスタンスのポート番号。デフォルト値: 6379。

   • password: Redis インスタンスへの接続に使用するパスワード。詳細については、「インスタンスに接続する」をご参照ください。

   • key: 削除したいキーに一致させるために使用するパターン。たとえば、"test*" は、test プレフィックスを持つすべてのキーに一致します。例: test1、test2、test3。

     次の例は、パターンマッチングにワイルドカードを使用する方法を示しています:

     • w?rld: w で始まり、rld で終わる 5 文字の文字列 (world、warld、wxrld など) に一致します。

     • w*rld: w で始まり、rld で終わる任意の文字列に一致します。たとえば wrld や woooorld などです。

     • w[ae]rld: warld と werld には一致しますが、world には一致しません。

     • w[^e]rld: world と warld には一致しますが、werld には一致しません。

     • w[a-b]rld: warld と wbrld に一致します。

高スループット削除のためにパイプラインモードを使用

このメソッドは、特定のパターンに一致するキーを繰り返しスキャンし、パイプラインを使用して UNLINK コマンドをバッチで送信します。このアプローチにより、ラウンドトリップタイム (RTT) が大幅に削減されます。

1. 次のコードを scan_and_unlink_pipe.py スクリプトとして保存します:

   import redis
   import sys
   
   
   def main(argv):
       if len(argv) < 4:
           print("Usage: python scan_and_del_pipeline.py host port password match")
           sys.exit(-1)
   
       host = argv[1]
       port = int(argv[2])  # ポートを整数に変換
       password = argv[3]
       match = argv[4]
       print(f"host: {host}, port: {port}, password: {'*' * len(password)}, match: {match}\n")
   
       # 1,000 個のキーを蓄積した後、パイプラインを通じて DEL コマンドを送信します。この数値は必要に応じて調整できます。
       pipeline_batch_size = 1000
       
       redis_cli = redis.StrictRedis(host=host, port=port, password=password, decode_responses=True)
       
       cursor = 0
       total_deleted_count = 0
       keys_to_delete = []
   
       print("Starting key scan...")
       # 'while True' ループを使用し、カーソルが 0 になったら終了します。
       while True:
           # 1. キーのバッチをスキャンします。
           cursor, keys = redis_cli.scan(cursor=cursor, match=match, count=1000)
   
           if keys:
               # 2. スキャンしたキーを削除用のリストに収集します。
               keys_to_delete.extend(keys)
   
           # 3. 削除リストがバッチサイズに達したとき、またはスキャンが完了したときに、削除を実行します。
           if len(keys_to_delete) >= pipeline_batch_size or cursor == 0:
               if keys_to_delete:
                   print(f"Accumulated {len(keys_to_delete)} keys. Preparing to delete via Pipeline...")
   
                   # --- パイプライン -----------
                   pipe = redis_cli.pipeline(transaction=False, shard_hint=None)
                   pipe.delete(*keys_to_delete)
                   result = pipe.execute()
                   # -------------------------
   
                   deleted_in_batch = result[0]
                   total_deleted_count += deleted_in_batch
   
                   print(f"  -> Pipeline executed. Deleted {deleted_in_batch} keys in this batch.")
   
                   # 次のバッチの準備のために削除リストをクリアします。
                   keys_to_delete = []
   
           # 4. スキャンが完了したら、ループを終了します。
           if cursor == 0:
               break
   
       print(f"\nScan finished. Total keys deleted: {total_deleted_count}")
   
   
   if __name__ == '__main__':
       main(sys.argv)
   

2. 次のコマンドを実行してスクリプトを実行します:

   python scan_and_unlink_pipe.py <host> <port> <password> "<key>" 

   パラメーター:

   • host: Redis インスタンスのエンドポイント。

   • port: Redis インスタンスのポート番号。デフォルト値: 6379。

   • password: Redis インスタンスへの接続に使用するパスワード。詳細については、「インスタンスに接続する」をご参照ください。

   • key: 削除したいキーに一致させるために使用するパターン。たとえば、"test*" は、test プレフィックスを持つすべてのキーに一致します。例: test1、test2、test3。

     次の例は、パターンマッチングにワイルドカードを使用する方法を示しています:

     • w?rld: w で始まり rld で終わる、world、warld、wxrld などの 5 文字の文字列に一致します。

     • w*rld: w で始まり rld で終わる文字列に一致します。たとえば、wrld や woooorld などです。

     • w[ae]rld: warld と werld には一致しますが、world には一致しません。

     • w[^e]rld: world と warld には一致しますが、werld には一致しません。

     • w[a-b]rld: warld と wbrld に一致します。

KEYS と DEL を使用

次のコマンドを実行して、指定されたパターンに一致するキーを削除します:

redis-cli -h <host> -p <port> -a <password> KEYS "<key>" | xargs redis-cli -h <host> -p <port> -a <password> DEL

このコマンドは、KEYS とワイルドカード パターンを使用して一致するすべてのキーを検索し、それらを xargs にパイプします。これにより、キーが DEL に渡されて削除されます。

パラメーター:

• host: Redis インスタンスのエンドポイント。

• port: Redis インスタンスのポート番号。デフォルト値: 6379。

• password: Redis インスタンスへの接続に使用するパスワード。詳細については、「インスタンスに接続する」をご参照ください。

• key: 削除したいキーに一致させるために使用するパターン。たとえば、"test*" は、test プレフィックスを持つすべてのキーに一致します。例: test1、test2、test3。

  次の例は、パターンマッチングにワイルドカードを使用する方法を示しています:

  • w?rld: w で始まり、rld で終わる、world、warld、wxrld などの 5 文字の文字列に一致します。

  • w*rld: w で始まり rld で終わる、wrld や woooorld などの任意の文字列に一致します。

  • w[ae]rld: warld と werld には一致しますが、world には一致しません。

  • w[^e]rld: world と warld には一致しますが、werld には一致しません。

  • w[a-b]rld: warld と wbrld に一致します。

コマンドの例:

redis-cli -h r-bp127cu5tb*****.redis.rds.aliyuncs.com -a Test**** KEYS "keys*" | xargs redis-cli -h r-bp127cu5tb*****.redis.rds.aliyuncs.com -a Test**** DEL