diff --git a/README.md b/README.md index dd3a048..03b8f72 100644 --- a/README.md +++ b/README.md @@ -49,6 +49,10 @@ batch.events = [SessionStartEvent(), app_event, SessionEndEvent()] configuration = mparticle.Configuration() configuration.api_key = 'REPLACE WITH API KEY' configuration.api_secret = 'REPLACE WITH API SECRET' + +# Raise the connection pool size if necessary (defaults to 1) +# configuration.connection_pool_size = 50 + api_instance = mparticle.EventsApi(configuration) # synchronous diff --git a/mparticle/configuration.py b/mparticle/configuration.py index db5b3bb..e4369c0 100644 --- a/mparticle/configuration.py +++ b/mparticle/configuration.py @@ -89,6 +89,8 @@ def __init__(self): self.cert_file = None # client key file self.key_file = None + # number of simultaneous connection to maintain + self.connection_pool_size = 1 @property def logger_file(self): diff --git a/mparticle/rest.py b/mparticle/rest.py index 5334e2a..3a7dafe 100644 --- a/mparticle/rest.py +++ b/mparticle/rest.py @@ -106,7 +106,8 @@ def __init__(self, pools_size=4, config=None): cert_reqs=cert_reqs, ca_certs=ca_certs, cert_file=cert_file, - key_file=key_file + key_file=key_file, + maxsize=config.connection_pool_size ) def request(self, method, url, query_params=None, headers=None,