need an async/non-blocking python sns publish() call

[archws225]

Describe the feature

the python implementation of publish() is taking too long (typically 70ms latency first call then plateaus around 20ms). I don't need to wait around for a success/failure response. I want to send and forget.

Use Case

No matter how much concurrency I introduce into my python script (asyncio, threadpooling, etc) the sns.publish() is still taking too long. i want to send and forget.

Proposed Solution

can we get an equivalent of amazonSNSAsync.publishAsync() for python?

Other Information

No response

Acknowledgements

• I may be able to implement this feature request
• This feature might incur a breaking change

SDK version used

2.85

Environment details (OS name and version, etc.)

linux

[tim-finnigan]

Thanks for the feature request. The request for async functionality is not under consideration until the next major version Boto3. Implementing async functionality would require an entire rewrite of Botocore (which provides the low-level core functionality for Boto3) and that effort is currently being allocated to creating a longer term async solution for Botocore users. I recommend tracking this blog for future announcements: https://aws.amazon.com/blogs/developer/.

[github-actions]

This issue is now closed. Comments on closed issues are hard for our team to see.
If you need more assistance, please open a new issue that references this one.

[gyund]

@archws225 as temporary workaround until async is supported, you could create a thread pool to wait on IO tasks with futures (if you care about the response).

https://docs.python.org/3/library/concurrent.futures.html

Since the GIL essentially limits CPU bound tasks and not I/O bound tasks, this should work for performing parallel requests and give your program the freedom to move on more efficiently. Just adding this for anyone that comes across this in the future...no pun intended :)

Also of note, await asyncio.to_thread(blocking_task) is another approach if you're already in an async routine and just want to dispatch a thread without managing it in a context like with ThreadPoolExecutor() as pool:.