May 2018
Beginner to intermediate
452 pages
11h 26m
English
Create a copy of CorporateResUploader and call it CorporateRestUploaderWithQueue:
class CorporateRestUploaderWithQueue(Thread):
def __init__(self, filepath, upload_url, auth_url,
username, password, queue):
...
self.queue = queue
...
The only difference in __init__() is the addition of a queue argument, which we store as an instance property. Just as in our example application, the Queue object will be created in the Application object and passed into the thread constructor.
Back in Application, update the call to the uploader class:
self.rest_queue = Queue() self.uploader = n.CorporateRestUploaderWithQueue( csvfile, self.settings['abq_upload_url'].get(), self.settings['abq_auth_url'].get(), ...