[BEAM-10137][BEAM-10138] Python wrapper KinesisIO integration tests

[pjotrekk]

Add python wrapper for KinesisIO.Read.

Chronology:

1. java write
2. java read
3. python wrapper
4. python integration tests

PR for java external transform for write: #12234
PR for python wrapper: #12235
PR for java external transform for read: #12297

I haven't managed to run this test yet. In the previous version (1st commit) it succeeded on my AWS account. But when I try to run the same pipelines on localstack I get com.amazonaws.services.kinesis.producer.UserRecordFailedException.

Strange thing is that with below code I can use the container, so it works.

 client.put_record(
StreamName='beam',
Data=b'bytes',
PartitionKey='a',
)
shard_iterator = client.get_shard_iterator(
StreamName=self.stream_name,
ShardId='shardId-000000000000',
ShardIteratorType='TRIM_HORIZON'
)
response = client.get_records(
ShardIterator=shard_iterator['ShardIterator'],
Limit=2
)

---

Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:

• Choose reviewer(s) and mention them in a comment (R: @username).
• Format the pull request title like [BEAM-XXX] Fixes bug in ApproximateQuantiles, where you replace BEAM-XXX with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.
• Update CHANGES.md with noteworthy changes.
• If this contribution is large, please file an Apache Individual Contributor License Agreement.

See the Contributor Guide for more tips on how to make review process smoother.

Post-Commit Tests Status (on master branch)

Lang	SDK	Dataflow	Flink	Samza	Spark	Twister2
Go		---		---		---
Java
Python				---		---
XLang		---		---		---

Pre-Commit Tests Status (on master branch)

---	Java	Python	Go	Website
Non-portable
Portable	---		---	---

See .test-infra/jenkins/README for trigger phrase, status and link of all Jenkins jobs.

[pjotrekk]

R: @TheNeuralBit Could I ask you for review?

[TheNeuralBit]

Closing in favor of #12297