/AWS1/CL_PISPIPESRCKINESISST00¶
The parameters for using a Kinesis stream as a source.
CONSTRUCTOR¶
IMPORTING¶
Required arguments:¶
iv_startingposition TYPE /AWS1/PISKINESISSTRMSTRTPOSI00 /AWS1/PISKINESISSTRMSTRTPOSI00¶
The position in a stream from which to start reading.
Optional arguments:¶
iv_batchsize TYPE /AWS1/PISLIMITMAX10000 /AWS1/PISLIMITMAX10000¶
The maximum number of records to include in each batch.
io_deadletterconfig TYPE REF TO /AWS1/CL_PISDEADLETTERCONFIG /AWS1/CL_PISDEADLETTERCONFIG¶
Define the target queue to send dead-letter queue events to.
iv_onpartialbatchitemfailure TYPE /AWS1/PISONPARTIALBTCITEMFAI00 /AWS1/PISONPARTIALBTCITEMFAI00¶
Define how to handle item process failures.
AUTOMATIC_BISECThalves each batch and retry each half until all the records are processed or there is one failed message left in the batch.
iv_maxbatchingwindowinsecs TYPE /AWS1/PISMAXBTCINGWINDOWINSECS /AWS1/PISMAXBTCINGWINDOWINSECS¶
The maximum length of a time to wait for events.
iv_maximumrecordageinseconds TYPE /AWS1/PISMAXRECORDAGEINSECONDS /AWS1/PISMAXRECORDAGEINSECONDS¶
Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.
iv_maximumretryattempts TYPE /AWS1/PISMAXRETRYATTEMPTSESM /AWS1/PISMAXRETRYATTEMPTSESM¶
Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.
iv_parallelizationfactor TYPE /AWS1/PISLIMITMAX10 /AWS1/PISLIMITMAX10¶
The number of batches to process concurrently from each shard. The default value is 1.
iv_startingpositiontimestamp TYPE /AWS1/PISTIMESTAMP /AWS1/PISTIMESTAMP¶
With
StartingPositionset toAT_TIMESTAMP, the time from which to start reading, in Unix time seconds.
Queryable Attributes¶
BatchSize¶
The maximum number of records to include in each batch.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_BATCHSIZE() |
Getter for BATCHSIZE, with configurable default |
ASK_BATCHSIZE() |
Getter for BATCHSIZE w/ exceptions if field has no value |
HAS_BATCHSIZE() |
Determine if BATCHSIZE has a value |
DeadLetterConfig¶
Define the target queue to send dead-letter queue events to.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_DEADLETTERCONFIG() |
Getter for DEADLETTERCONFIG |
OnPartialBatchItemFailure¶
Define how to handle item process failures.
AUTOMATIC_BISECThalves each batch and retry each half until all the records are processed or there is one failed message left in the batch.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_ONPARTIALBTCITEMFAILURE() |
Getter for ONPARTIALBATCHITEMFAILURE, with configurable defa |
ASK_ONPARTIALBTCITEMFAILURE() |
Getter for ONPARTIALBATCHITEMFAILURE w/ exceptions if field |
HAS_ONPARTIALBTCITEMFAILURE() |
Determine if ONPARTIALBATCHITEMFAILURE has a value |
MaximumBatchingWindowInSeconds¶
The maximum length of a time to wait for events.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_MAXBATCHINGWINDOWINSECS() |
Getter for MAXBATCHINGWINDOWINSECONDS, with configurable def |
ASK_MAXBATCHINGWINDOWINSECS() |
Getter for MAXBATCHINGWINDOWINSECONDS w/ exceptions if field |
HAS_MAXBATCHINGWINDOWINSECS() |
Determine if MAXBATCHINGWINDOWINSECONDS has a value |
MaximumRecordAgeInSeconds¶
Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_MAXRECORDAGEINSECONDS() |
Getter for MAXIMUMRECORDAGEINSECONDS, with configurable defa |
ASK_MAXRECORDAGEINSECONDS() |
Getter for MAXIMUMRECORDAGEINSECONDS w/ exceptions if field |
HAS_MAXRECORDAGEINSECONDS() |
Determine if MAXIMUMRECORDAGEINSECONDS has a value |
MaximumRetryAttempts¶
Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_MAXIMUMRETRYATTEMPTS() |
Getter for MAXIMUMRETRYATTEMPTS, with configurable default |
ASK_MAXIMUMRETRYATTEMPTS() |
Getter for MAXIMUMRETRYATTEMPTS w/ exceptions if field has n |
HAS_MAXIMUMRETRYATTEMPTS() |
Determine if MAXIMUMRETRYATTEMPTS has a value |
ParallelizationFactor¶
The number of batches to process concurrently from each shard. The default value is 1.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_PARALLELIZATIONFACTOR() |
Getter for PARALLELIZATIONFACTOR, with configurable default |
ASK_PARALLELIZATIONFACTOR() |
Getter for PARALLELIZATIONFACTOR w/ exceptions if field has |
HAS_PARALLELIZATIONFACTOR() |
Determine if PARALLELIZATIONFACTOR has a value |
StartingPosition¶
The position in a stream from which to start reading.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_STARTINGPOSITION() |
Getter for STARTINGPOSITION, with configurable default |
ASK_STARTINGPOSITION() |
Getter for STARTINGPOSITION w/ exceptions if field has no va |
HAS_STARTINGPOSITION() |
Determine if STARTINGPOSITION has a value |
StartingPositionTimestamp¶
With
StartingPositionset toAT_TIMESTAMP, the time from which to start reading, in Unix time seconds.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_STARTINGPOSITIONTSMP() |
Getter for STARTINGPOSITIONTIMESTAMP, with configurable defa |
ASK_STARTINGPOSITIONTSMP() |
Getter for STARTINGPOSITIONTIMESTAMP w/ exceptions if field |
HAS_STARTINGPOSITIONTSMP() |
Determine if STARTINGPOSITIONTIMESTAMP has a value |