烧瓶BOTO3 SQS集成
Flask-BotoSQS的Python项目详细描述
初始化
from flask_boto_sqs import FlaskBotoSQS flask_boto_sqs = FlaskBotoSQS(app)
或:
flask_boto_sqs = FlaskBotoSQS() flask_boto_sqs.init_app(app)
配置
在您的烧瓶配置中,将烧瓶的夸克设置为“烧瓶夸克”。
app.config['FLASK_BOTO_SQS'] = { 'region': 'ap-northeast-1', 'aws_access_key_id': 'YOUR_AWS_ACCESS_KEY_ID', 'aws_secret_access_key': 'YOUR_AWS_SECRET_ACCESS_KEY' }
用法
# https://boto3.readthedocs.org/en/latest/guide/sqs.html q = flask_boto_sqs.sqs.get_queue_by_name(QueueName='your-queue-name') # write resp = q.send_message('What a lovely day!') print resp.get('MessageId') # read for m in q.receive_messages(): print m.body m.delete()