PutKinesisStream Processor
类型全限定名：cn.org.acal.lynxus.processors.aws.kinesis.stream.PutKinesisStream
所属 Bundle：cn.org.acal.lynxus:lynxus-aws-nar:2.11.8
描述
将内容发送到指定的 Amazon Kinesis。 为了将数据发送到 Kinesis，必须指定流名称。
标签
amazonawskinesisputstream
属性
下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。
| 名称 | 默认值 | 可选值 | 描述 |
|---|
| Stream Name | | | Kinesis 流的名称
支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） |
| Region | us-west-2 | - Africa (Cape Town) — AWS Region Code : af-south-1
- Asia Pacific (Hong Kong) — AWS Region Code : ap-east-1
- Asia Pacific (Hyderabad) — AWS Region Code : ap-south-2
- Asia Pacific (Jakarta) — AWS Region Code : ap-southeast-3
- Asia Pacific (Malaysia) — AWS Region Code : ap-southeast-5
- Asia Pacific (Melbourne) — AWS Region Code : ap-southeast-4
- Asia Pacific (Mumbai) — AWS Region Code : ap-south-1
- Asia Pacific (New Zealand) — AWS Region Code : ap-southeast-6
- Asia Pacific (Osaka) — AWS Region Code : ap-northeast-3
- Asia Pacific (Seoul) — AWS Region Code : ap-northeast-2
- Asia Pacific (Singapore) — AWS Region Code : ap-southeast-1
- Asia Pacific (Sydney) — AWS Region Code : ap-southeast-2
- Asia Pacific (Taipei) — AWS Region Code : ap-east-2
- Asia Pacific (Thailand) — AWS Region Code : ap-southeast-7
- Asia Pacific (Tokyo) — AWS Region Code : ap-northeast-1
- AWS European Sovereign Cloud (Germany) — AWS Region Code : eusc-de-east-1
- aws global region — AWS Region Code : aws-global
- AWS GovCloud (US-East) — AWS Region Code : us-gov-east-1
- AWS GovCloud (US-West) — AWS Region Code : us-gov-west-1
- aws-cn global region — AWS Region Code : aws-cn-global
- aws-iso global region — AWS Region Code : aws-iso-global
- aws-iso-b global region — AWS Region Code : aws-iso-b-global
- aws-iso-e global region — AWS Region Code : aws-iso-e-global
- aws-iso-f global region — AWS Region Code : aws-iso-f-global
- aws-us-gov global region — AWS Region Code : aws-us-gov-global
- Canada (Central) — AWS Region Code : ca-central-1
- Canada West (Calgary) — AWS Region Code : ca-west-1
- China (Beijing) — AWS Region Code : cn-north-1
- China (Ningxia) — AWS Region Code : cn-northwest-1
- EU ISOE West — AWS Region Code : eu-isoe-west-1
- Europe (Frankfurt) — AWS Region Code : eu-central-1
- Europe (Ireland) — AWS Region Code : eu-west-1
- Europe (London) — AWS Region Code : eu-west-2
- Europe (Milan) — AWS Region Code : eu-south-1
- Europe (Paris) — AWS Region Code : eu-west-3
- Europe (Spain) — AWS Region Code : eu-south-2
- Europe (Stockholm) — AWS Region Code : eu-north-1
- Europe (Zurich) — AWS Region Code : eu-central-2
- Israel (Tel Aviv) — AWS Region Code : il-central-1
- Mexico (Central) — AWS Region Code : mx-central-1
- Middle East (Bahrain) — AWS Region Code : me-south-1
- Middle East (UAE) — AWS Region Code : me-central-1
- South America (Sao Paulo) — AWS Region Code : sa-east-1
- US East (N. Virginia) — AWS Region Code : us-east-1
- US East (Ohio) — AWS Region Code : us-east-2
- US ISO East — AWS Region Code : us-iso-east-1
- US ISO WEST — AWS Region Code : us-iso-west-1
- US ISOB East (Ohio) — AWS Region Code : us-isob-east-1
- US ISOB West — AWS Region Code : us-isob-west-1
- US ISOF EAST — AWS Region Code : us-isof-east-1
- US ISOF SOUTH — AWS Region Code : us-isof-south-1
- US West (N. California) — AWS Region Code : us-west-1
- US West (Oregon) — AWS Region Code : us-west-2
- Use Custom Region — 用户定义的区域，可以是非 AWS 区域，和/或来自表达式语言（Expression Language）
| 服务所在的 AWS 区域 |
| Custom Region | | | 自定义区域，例如 AWS 兼容服务提供商的区域
支持表达式语言：是（仅使用环境/系统变量求值） |
| AWS Credentials Provider Service | | 控制器服务 API：
AwsCredentialsProviderService
cn.org.acal.lynxus-lynxus-aws-service-api-nar-2.11.8 | 用于获取AWS凭证提供者的Controller Service |
| Stream Partition Key | ${kinesis.partition.key} | | 分区键属性。如果未设置，则使用随机值
支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值） |
| Message Batch Size | 250 | | 消息的批量大小 (1-500)。 |
| Max Message Buffer Size | 1 MB | | 使用标准数据大小单位定义的最大消息缓冲区大小 |
| Communications Timeout | 30 secs | | |
| Proxy Configuration Service | | 控制器服务 API：
ProxyConfigurationService
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定代理配置 Controller Service 来代理网络请求。 |
| Endpoint Override URL | | | 用于替代 AWS 默认端点的端点 URL，包括协议、主机、端口和路径。AWS 库根据 AWS 区域选择端点 URL，但此属性会覆盖所选端点 URL，允许与其他 S3 兼容端点一起使用。
支持表达式语言：是（仅使用环境/系统变量求值） |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|
failure | FlowFiles被路由到故障关系 | 否 |
success | FlowFiles被路由到成功关系 | 否 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|
aws.kinesis.error.message | 将消息发布到 AWS Kinesis 时出现错误消息 |
aws.kinesis.error.code | 发布到 AWS Kinesis 时消息的错误代码 |
aws.kinesis.sequence.number | 发布到 AWS Kinesis 时消息的序列号 |
aws.kinesis.shard.id | 发布到 AWS Kinesis 的消息的分片 ID |