fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-09-15 21:47:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #283 from svdgraaf/feature/make-sqs-credentials-optional

Browse Source 
Allow SQS to use environment variables
This commit is contained in:
Ilan Steemers
2018-01-09 13:36:05 +01:00
committed by GitHub
parent e22546672e 17ea1e7a7b
commit c8599fee22
2 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
django_q/brokers/aws_sqs.py
View File

@@ -51,9 +51,12 @@ class Sqs(Broker):
@staticmethod
def get_connection(list_key=Conf.PREFIX):
return Session(aws_access_key_id=Conf.SQS['aws_access_key_id'],
aws_secret_access_key=Conf.SQS['aws_secret_access_key'],
region_name=Conf.SQS['aws_region'])
config = Conf.SQS
if 'aws_region' in config:
config['region_name'] = config['aws_region']
del(config['aws_region'])
return Session(**config)
def get_queue(self):
self.sqs = self.connection.resource('sqs')

8
docs/configure.rst
View File

@@ -229,7 +229,7 @@ All connection keywords are supported. See the `iron-mq <https://github.com/iron
sqs
~~~
To use Amazon SQS as a broker you need to provide the AWS region and credentials::
To use Amazon SQS as a broker you need to provide the AWS region and credentials either via the config, or any other boto3 configuration method::
# example SQS broker connection
@@ -241,9 +241,9 @@ To use Amazon SQS as a broker you need to provide the AWS region and credentials
'queue_limit': 100,
'bulk': 5,
'sqs': {
'aws_region': 'us-east-1',
'aws_access_key_id': 'ac-Idr.....YwflZBaaxI',
'aws_secret_access_key': '500f7b....b0f302e9'
'aws_region': 'us-east-1', # optional
'aws_access_key_id': 'ac-Idr.....YwflZBaaxI', # optional
'aws_secret_access_key': '500f7b....b0f302e9' # optional
}
}