Является ли публикация сообщения в потоке Kinesis асинхронной?

Question

Является ли публикация сообщения в потоке Kinesis асинхронной, или есть ли способ запустить его асинхронно с помощью GoLang SDK API?

Answer 1

Нет, это синхронно.

Когда вы вызываете конечную точку API PutRecord, запись записывается в Kinesis, и в качестве ответа возвращаются «ShardId» и «SequenceNumber». Это показывает, где записанные данные помещаются в поток (осколок).

См. Документ: https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html

Answer 2

Документация , похоже, довольно подробно описывает, какие операции являются асинхронными, поэтому я бы сказал нет: отправка сообщения не является асинхронной. Но в любом случае это имеет смысл - как можно вернуть ошибку, если операция еще не завершена?

Но вы можете сделать это асинхронным? Конечно. В Go сделать что-нибудь асинхронным тривиально - просто запустите его в программе.

Если вы новичок в goroutines, Тур по Го - отличное введение в концепцию.