Как реализовать реконект к БД каждые N секунд?

Question

[hardwellZero]

Добрый вечер.
Есть вот такая функция:

def __init__(self):
        ''' creates a connection at the initialization moment
        and also a cursor used later '''
 
        try:
            # creates a connection
            self.conn = MySQLdb.connect(  host = self.dbhost,
                                        port = self.dbport,
                                        user = self.dbuser,
                                        passwd = self.dbpass
                                    )
            self.cursor = self.conn.cursor()
        except MySQLdb.Error, e:
            print "Error %d: %s" % (e.args[0], e.args[1])
            
            sys.exit (1)

Сейчас хочу реализовать так, что-бы при ошибке подключения, через 5 секунд происходил реконект и так по кругу до успешного подключения.
Как можно прикрутить такое? Видел как реализовано с кол-вом попыток, но это не то.

Answer 1

[Melkij]

В чём проблема? Зациклите код вместо exit'а по условию успешности установленного коннекта
Псевдокод:
is_connect_success = false
do
try
//connect
is_connect_success = true
except
print error
sleep 5 seconds
while (is_connect_success)

Comments

[hardwellZero]

Уже так и сделал. Спасибо ;)

Answer 2

[Алексей Волегов]

while (1 == 1) кто-то отменял?

Comments

[hardwellZero]

Что Вы имеете ввиду?

[Алексей Волегов]

Я не бетонщик, но как могу догадаться вы ходите накапливать записи и при создании соединения их записывать.

Накапливать и пытаться отправить — разные потоки.

Отправте поток соединения (что в вашем примере) в бесконечный цикл с задержкой 5с после каждой попытки и при открытии соединения отправляйте данные.

[Алексей Волегов]

* питонщик =)

[hardwellZero]

Алексей Волегов: Да, нужно как-то проще решить. Прикрутить повтор реконекта да и все.

Answer 3

[Дмитрий Демидов]

Как-то так:

def __init__(self):
    while True:
        ''' creates a connection at the initialization moment
        and also a cursor used later '''
 
        try:
            # creates a connection
            self.conn = MySQLdb.connect(  host = self.dbhost,
                                        port = self.dbport,
                                        user = self.dbuser,
                                        passwd = self.dbpass
                                    )
            self.cursor = self.conn.cursor()
            break
        except MySQLdb.Error, e:
            print "Error %d: %s" % (e.args[0], e.args[1])
            time.sleep(5)

Answer 4

[Vladimir Abramov]

А нафига вам велосипед?

docs.sqlalchemy.org/en/latest/core/pooling.html или
dev.mysql.com/doc/connector-python/en/connector-py... чем не устраивает?