On Sep 22, 2014, at 4:21 PM, Milind Vaidya <kava...@gmail.com> wrote:
> > In simple words my application is doing following thing, > > There are 'n' tracks (some entity in business logic context) > every 5 mins per track have a thread--->each thread will spawn 5 threads per > mins--> now each of these threads will fetch data from web service and insert > into DB. > > > class DBHandler(object): > '''Handles generic DB related operations''' > > def __init__(self): > global engine > self.session = Session(bind=engine) > > def execute_query(): > > > def insert_data(): > dbh = DBHandler() > > > > def fetch_insert_data() > fetch_data() > insert_data() > > > def processing(track) > create 5 threads per minute in 5 min interval and call > fetch_insert_data(track, minute_value) > > def main(): > create thread per track and call processing(track) > > 90% of the queries are insert queries and very few are fetch with no complex > joins or anything. I understand that it will be difficult to get the whole > picture with these code snippets. the "out of sync" error means connections/cursors are being used in an order that's not expected, I've given you all the info I have on this. -- You received this message because you are subscribed to the Google Groups "sqlalchemy" group. To unsubscribe from this group and stop receiving emails from it, send an email to sqlalchemy+unsubscr...@googlegroups.com. To post to this group, send email to sqlalchemy@googlegroups.com. Visit this group at http://groups.google.com/group/sqlalchemy. For more options, visit https://groups.google.com/d/optout.
