KinesisReceiver
使用亚马逊Kinesis service, receives data records from an Amazon Kinesis stream.
Input Ports
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
When a feature is input, KinesisReceiver will commence retrieving data from the Kinesis stream.
Output Ports
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
功能包含指定的Amazon Kinesis流中的数据记录。数据记录的内容和其他细节存储为特征的属性。使用以下属性:
属性 | 描述 |
---|---|
sequence_number | The sequence number of the data record. |
partition_key | The partition key of the data record. |
data_blob | The data blob of the data record. |
shard_id. | The id of the shard which contained the data record. |
Parameters
Amazon Kinesis Parameters
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
The name of the Kinesis stream from which data records are to be received.
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
创建了Kinesis流的AWS区域。
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
与用户相关联的访问密钥,其许可用于从流接收数据记录。
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
A secret key paired with the access key provided.
Receiver Options
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
The name of the application processing the Kinesis stream.
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
The idle time in seconds between reads from the Kinesis stream. Minimum is 0.001 seconds and can be up to 3 decimal spaces.
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
从每个读取的Kinesis流可以收到的最大记录数。最大是10,000个数据记录。
停止条件
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
如果None, the receiver runs indefinitely. IfMax Polling Time,在几秒钟内输入最大的轮询时间Max Polling Time。如果Max Records Output, enter a maximum number of data records to be output in最大记录输出。如果Both,输入两者的值Max Polling Time和最大记录输出。Whichever of these two stopping conditions is met first will cause the receiver to stop reading from the stream.
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
在kinesis流中没有收到数据记录的最长时间。一旦初始化流中的所有碎片都会开始轮询时间。一旦到达最大轮询时间,接收器将停止读取流。最小值为1秒钟,必须是整数值。
![关闭](http://www.baooytra.com/docs/fme/2017.0/html/FME_Desktop_Documentation/FME_Transformers/Transformers/../Skins/Default/Stylesheets/Images/transparent.gif)
The maximum number of data records to be output by the transformer. Once the maximum number of records has been output, the receiver will stop reading from the stream.
编辑变换器参数
使用一组菜单选项,可以通过引用工作区中的其他元素来分配变压器参数。一些变压器也可提供更高级的功能,例如高级编辑器和算术编辑器。要访问这些选项的菜单,请单击除适用的参数旁边。有关更多信息,请参阅变换器参数菜单选项。
变压器类别
FME Licensing Level
FME Professional edition and above
Search FME Knowledge Center
Search for samples and information about this transformer on theFME Knowledge Center。