create_slots_test.py

#!/usr/bin/python3

import sys

import psycopg2


conn = psycopg2.connect(sys.argv[1])
conn.set_session(autocommit=True)
cursor = conn.cursor()

cursor.execute("SELECT pg_drop_replication_slot(slot_name) FROM pg_replication_slots WHERE slot_name LIKE 'test_%';")

for index in range(0, 40):
    print(index)
    cursor.execute("CHECKPOINT;")
    cursor.execute(f"SELECT pg_create_logical_replication_slot('test_{index}', 'pgoutput', false);")