PrivacyScanData/S3/NatsExample/nats_produce_async.py

import asyncio
import nats
from time import sleep
from data_develop import develop_random_data
from config import (
    nats_url,
    nats_subject,
    index_end,
    index_begin
)


async def develop_publish(nc:object):
    """
    Function which is about the development of the
    Input:  nc = nats connection
    Output: we developed the publish
    """
    for i in range(index_begin, index_end):
        await nc.publish(
            nats_subject, 
            develop_random_data(i).encode()
        )
        sleep(0.02)
        print(f'Sent Index: ', i)
        print('>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>')

async def main():
    nc = await nats.connect(nats_url)
    await develop_publish(nc)
    await nc.flush()
    await nc.close()


if __name__ == '__main__':
    asyncio.run(main())