Как отправлять сообщения из сервиса aiohttp в SQS-очередь? - PullRequest
Новая
       14

Как отправлять сообщения из сервиса aiohttp в SQS-очередь?

0 голосов
/ 17 июня 2019

Мне нужно отправлять сообщения в очередь SQS из сервиса aiohttp. Я читаю документацию aiobotocore и все примеры, но ничего не вижу, как отправлять сообщения, аналогичные postgres, из aipg для пример . 

async def pg_engine(app):
    app['pg_engine'] = await create_engine(
        user='postgre',
        database='postgre',
        host='localhost',
        port=5432,
        password=''
    )
    yield
    app['pg_engine'].close()
    await app['pg_engine'].wait_closed()

app.cleanup_ctx.append(pg_engine)

UPD Решение 

async def sqs_client(app):
    session = get_session(loop=app.loop)
    app['sqs'] = session.create_client('sqs',
                                       endpoint_url=SQS_QUEUE_URL,
                                       region_name=SQS_REGION)
    yield
    # close connection after finish
    await app['sqs'].close()

app.cleanup_ctx.append(sqs_client)
...