Commit bfa1e41
committed
Release 1.4.0 of the Amazon Kinesis Client for Python
* Added a new v2 record processor class that allows access to updated features.
* Record processor initialization
* The initialize method receives an InitializeInput object that
provides shard id, and the starting sequence and sub sequence numbers.
* Process records calls
* The process_records calls now receives a ProcessRecordsInput
object that, in addition to the records, now includes the
millisBehindLatest for the batch of records
* Records are now represented as a Record object that adds new data,
and includes some convenience methods
* Adds a `binary_data` method that handles the base 64 decode of the data.
* Includes the sub sequence number of the record.
* Includes the approximate arrival time stamp of the record.
* Record processor shutdown
* The method `shutdown` now receives a `ShutdownInput` object.
* Checkpoint methods now accept a sub sequence number in addition to the
sequence number.1 parent fb49c63 commit bfa1e41
1 file changed
Lines changed: 14 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
137 | 137 | | |
138 | 138 | | |
139 | 139 | | |
| 140 | + | |
| 141 | + | |
| 142 | + | |
| 143 | + | |
| 144 | + | |
| 145 | + | |
| 146 | + | |
| 147 | + | |
| 148 | + | |
| 149 | + | |
| 150 | + | |
| 151 | + | |
| 152 | + | |
| 153 | + | |
140 | 154 | | |
141 | 155 | | |
142 | 156 | | |
| |||
0 commit comments