Hi,
I am writing a standalone program that uses SQLAlchemy for DB related
ops. The program is a log parser that runs continuously, processes the
log file and writes those entries to the database.
Connection to DB is done like so
engine = create_engine('mysql+mysqldb://root:root123@localhost/
mydb',pool_recycle=1800)
DBSession = sessionmaker(bind=engine)
session = DBSession()
Base = declarative_base()
Then my table def
class Statistics(Base):
__tablename__ = 'statistics'
col1 = Column(Integer,primary_key=True)
col2 = Column(DateTime)
Finally somewhere deep in my processing code I write the values
(already arranged as a list of dictionaries) to the DB
session.execute(Statistics.__table__.insert().prefix_with(' ignore
'),entry_list)
The program runs well but I want it to handle server disconnects as
well (Perform book-keeping before raising exception and exiting
sanely).In the link (http://docs.sqlalchemy.org/en/rel_0_7/core/
pooling.html) you have explained a method of handling DB disconnects
'pessimistically' with a caveat "provided that the database server is
actually running". But how to handle server stoppage?
Currently the program throws an exception at execute()
OperationalError 2002 - Can't connect to server. Should I use try
except OperationalError for every DB statement? I tried using events
(connect, first_connect) but they don't fit
Regards
--
You received this message because you are subscribed to the Google Groups
"sqlalchemy" group.
To post to this group, send email to sqlalchemy@googlegroups.com.
To unsubscribe from this group, send email to
sqlalchemy+unsubscr...@googlegroups.com.
For more options, visit this group at
http://groups.google.com/group/sqlalchemy?hl=en.
