Did I find the right examples for you? yes no

All Samples(57)  |  Call(57)  |  Derive(0)  |  Import(0)
:type aws_access_key_id: string
:param aws_access_key_id: Your AWS Access Key ID

:type aws_secret_access_key: string
:param aws_secret_access_key: Your AWS Secret Access Key

:rtype: :class:`boto.sqs.connection.SQSConnection`
:return: A connection to Amazon's SQS

        def connect_sqs(aws_access_key_id=None, aws_secret_access_key=None, **kwargs):
    """
    :type aws_access_key_id: string
    :param aws_access_key_id: Your AWS Access Key ID

    :type aws_secret_access_key: string
    :param aws_secret_access_key: Your AWS Secret Access Key

    :rtype: :class:`boto.sqs.connection.SQSConnection`
    :return: A connection to Amazon's SQS
    """
    from boto.sqs.connection import SQSConnection
    return SQSConnection(aws_access_key_id, aws_secret_access_key, **kwargs)
        


src/a/w/aws-sqs-alert-0.1.1/AWSSQSAlert/__init__.py   aws-sqs-alert(Download)
    def _connect(self):
        if self.sqs is None:
            self.sqs = boto.connect_sqs(aws_access_key_id=self.config['AWS_ACCESS'], aws_secret_access_key=self.config['AWS_SECRET'], region=self.region)
            self.queue = self.sqs.get_queue(self.config['queue'])
 

src/b/o/botoweb-HEAD/botoweb/environment.py   botoweb(Download)
		if aws_secret_access_key == None:
			aws_secret_access_key = self.config.get("Credentials", "aws_secret_access_key")
		return boto.connect_sqs(aws_access_key_id, aws_secret_access_key, **kwargs)
 
	def connect_s3(self, aws_access_key_id=None, aws_secret_access_key=None, **kwargs):

src/d/j/django-pdf-1.0.2/pdf/tasks.py   django-pdf(Download)
    def _dequeue_json_message(self):
        sqs = boto.connect_sqs(settings.PDF_AWS_KEY, settings.PDF_AWS_SECRET)
        queue = sqs.create_queue(RESPONSE_QUEUE)
        msg = queue.read()
        if msg is not None:
    def run(self, **kwargs):
        ec2 = boto.connect_ec2(settings.PDF_AWS_KEY, settings.PDF_AWS_SECRET)
        sqs = boto.connect_sqs(settings.PDF_AWS_KEY, settings.PDF_AWS_SECRET)
 
        queue = sqs.create_queue(REQUEST_QUEUE)

src/d/j/django-pdf-HEAD/pdf/tasks.py   django-pdf(Download)
    def _dequeue_json_message(self):
        sqs = boto.connect_sqs(settings.PDF_AWS_KEY, settings.PDF_AWS_SECRET)
        queue = sqs.create_queue(RESPONSE_QUEUE)
        msg = queue.read()
        if msg is not None:
    def run(self, **kwargs):
        ec2 = boto.connect_ec2(settings.PDF_AWS_KEY, settings.PDF_AWS_SECRET)
        sqs = boto.connect_sqs(settings.PDF_AWS_KEY, settings.PDF_AWS_SECRET)
 
        queue = sqs.create_queue(REQUEST_QUEUE)

src/t/s/tsudat2-HEAD/run_tsudat/ec2_bootstrap.py   tsudat2(Download)
    access_key = os.environ['EC2_ACCESS_KEY']
    secret_key = os.environ['EC2_SECRET_ACCESS_KEY']
    sqs = boto.connect_sqs(access_key, secret_key)
    access_key = 'DEADBEEF'
    secret_key = 'DEADBEEF'

src/m/e/media-nommer-HEAD/media_nommer/core/job_state_backend.py   media-nommer(Download)
        if not cls.__aws_sqs_connection:
            cls.__aws_sqs_connection = boto.connect_sqs(
                settings.AWS_ACCESS_KEY_ID,
                settings.AWS_SECRET_ACCESS_KEY)
        return cls.__aws_sqs_connection

src/t/s/tsudat2-HEAD/run_tsudat/sqs_listen_del.py   tsudat2(Download)
    print('Reading queue %s and deleting messages' % qname)
 
    sqs = boto.connect_sqs(os.environ['EC2_ACCESS_KEY'],
                           os.environ['EC2_SECRET_ACCESS_KEY'])
    queue = sqs.create_queue(SQSQueueName)

src/t/s/tsudat2-HEAD/run_tsudat/dump_sqs.py   tsudat2(Download)
      % (SQSQueueName, '- deleting messages' if Delete else ''))
 
sqs = boto.connect_sqs(os.environ['EC2_ACCESS_KEY'],
                       os.environ['EC2_SECRET_ACCESS_KEY'])
queue = sqs.create_queue(SQSQueueName)

src/w/e/webutils-0.9.6/webutils/aws/sqsproc.py   webutils(Download)
    def connect(self):
        self.conn = boto.connect_sqs(self.aws_key, self.aws_secret_key)
        self.queue = self.set_queue(self.queue_name)
        return True
 

src/c/h/check_sqs_queue-HEAD/check_sqs_queue.py   check_sqs_queue(Download)
def get_queue_count(queue, aws_id, aws_key):
	"""Count the number of messages in a queue"""
	# Create connection to specified queue
	conn = boto.connect_sqs(aws_id, aws_key)
	if conn.get_queue(queue):

  1 | 2 | 3 | 4  Next