KinesisReceiver
使用亚马逊Kinesis服务,接收来自亚马逊Kinesis流的数据记录。
使用笔记
这个转换器的性能取决于分配给Java虚拟机(JVM)的内存量。以下环境变量允许您指定Java插件可用的内存:
- FME_JVM_MIN_HEAP_SIZE:用于初始化JVM的初始堆大小。默认值是1024K。
- FME_JVM_MAX_HEAP_SIZE:初始化JVM的最大堆大小。默认值是16384K。
如果未设置,JVM将应用默认值。如果设置,值必须是1024K的倍数(例如,4M和64M,或者4096K和32768K)。
注:要将FME使用的其他参数传递给Java虚拟机,请使用JAVA_TOOL_OPTIONS环境变量。
输入端口
当一个特征被输入时,KinesisReceiver将开始从Kinesis流中检索数据。
输出端口
包含来自指定Amazon Kinesis流的数据记录的功能。数据记录的内容和其他细节存储为特性的属性。使用以下属性:
属性 | 说明 |
---|---|
序号 | 数据记录的序列号。 |
分区键 | 数据记录的分区键。 |
数据块 | 数据记录的数据块。 |
碎片ID | 包含数据记录的碎片的ID。 |
参数
亚马逊运动参数
要从中接收数据记录的意志力流的名称。
自动气象站的区域,在那里运动能量流被创造出来。
与具有从流中接收数据记录权限的用户相关联的访问键。
与提供的访问密钥配对的密钥。
接收方的选择
处理运动数据流的应用程序的名称。
从Kinesis流读取数据之间的空闲时间(以秒为单位)。最小值为0.001秒,最多可达3位小数。
每读一次可以从Kinesis流接收的最大记录数。最多有10,000条数据记录。
停止条件
如果无,接收端无限运行。如果最大轮询时间,输入以秒为单位的最大轮询时间最大轮询时间。如果最大记录输出,输入要输出的最大数据记录数最大记录输出。如果两者,为两者输入值最大轮询时间和最大记录输出。首先满足这两个停止条件中的任何一个都会导致接收器停止从流中读取数据。
没有从运动数据流接收数据记录所花费的最大时间(以秒为单位)。轮询时间将在流中的所有碎片初始化之后开始。一旦达到最大轮询时间,接收方将停止从流中读取数据。最小值为1秒,并且必须是整数值。
变压器要输出的最大数据记录数。一旦输出了最大记录数,接收器将停止从流中读取数据。
编辑变压器参数
使用一组菜单选项,可以通过引用工作空间中的其他元素来分配transformer参数。更高级的功能,如高级编辑器和算术编辑器,也可以在一些转换器中使用。要访问这些选项的菜单,请单击在可适用的参数旁边。有关更多信息,请参见变压器参数菜单选项。
变压器的分类
FME授权级别
FME专业版及以上
搜索FME知识中心
有关此变压器的示例和信息,请参阅FME知识中心。