Flex Gateway新着情報
Governance新着情報
Monitoring API ManagerAmazon Kinesis Data Streams Connector では、バージョン 0.14.0 以降の Windows サポートが廃止された Kinesis Producer Library (KPL) を使用しているため、Windows はサポートされません。 |
コネクタの設定。この設定は、プロデューサーとコンシューマーの両方に使用できます。
名前 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Name (名前) |
String (文字列) |
この設定の名前。コネクタはこの名前の設定を参照します。 |
x |
|
Connection (接続) |
この設定に指定する接続型。 |
x |
||
Aggregation Enabled (集約有効化) |
Boolean (ブール) |
|
true |
|
Response Timeout (応答タイムアウト) |
Number (数値) |
HTTP 要求の開始から応答が受信されるまで許容される最大合計時間。この時間を超えると、要求はタイムアウトします。 |
30 |
|
Request Timeout Unit (要求タイムアウト単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Response Timeout (応答タイムアウト)] 値の時間単位。 |
SECONDS (秒) |
|
Record Max Buffered Time (レコード最大バッファ時間) |
Number (数値) |
Amazon Kinesis データレコードが送信される前にバッファに費やす最大時間。他のバッファ制限によっては、この値よりも早くレコードを送信できます。 |
3 |
|
Record Max Buffered Time Unit (レコード最大バッファ時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Record Max Buffered Time (レコード最大バッファ時間)] 値の時間単位。 |
SECONDS (秒) |
|
Aggregation Max Count (集約最大数) |
Number (数値) |
集約された Amazon Kinesis データレコードにまとめる項目の最大数。 |
4294967295 |
|
Aggregation Max Size (集約最大サイズ) |
Number (数値) |
集約された Amazon Kinesis データレコードにまとめる最大データサイズ。 |
51200 |
|
Aggregation Max Size Unit (集約最大サイズ単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Aggregation Max Size (集約最大サイズ)] 値のデータ単位。 |
BYTE |
|
Collection Max Count (コレクション最大数) |
Number (数値) |
バッチ要求にまとめる項目の最大数。 |
500 |
|
Collection Max Size (コレクション最大サイズ) |
Number (数値) |
Put Record 操作で送信するデータの最大量。 |
5242880 |
|
Collection Max Size Unit (コレクション最大サイズ単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Collection Max Size (コレクション最大サイズ)] 値のデータ単位。 |
BYTE |
|
Connection Timeout (接続タイムアウト) |
Number (数値) |
接続が失敗した場合に例外をスローする前に、コネクタと Amazon Kinesis サーバー間の TCP 接続を最初に確立するときに待機する時間。 |
30 |
|
Connection Timeout Unit (接続タイムアウト単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Connection Timeout (接続タイムアウト)] 値の時間単位。 |
SECONDS (秒) |
|
Max Connections (最大接続数) |
Number (数値) |
バックエンドに対して開く接続の最大数。HTTP 要求は、複数の接続を介して並行して送信されます。この値の設定が高すぎると、レイテンシーに影響し、スループットを高めることなく追加リソースがコンシュームされる可能性があります。 |
24 |
|
Min Connections (最小接続数) |
Number (数値) |
バックエンドに対して開き続ける接続の最小数。ほとんどの場合、値を増やす必要はありません。 |
1 |
|
Rate Limit (レート制限) |
Number (数値) |
シャードに送信される 1 秒あたりのデータレコード数と 1 秒あたりのバイト数を制限します。この制限により、調整に失敗する要求の送信による帯域幅と CPU サイクルの浪費を減らすことができます。デフォルト値の 150% を使用すると、1 つのプロデューサーインスタンスでシャードの許容量を完全に飽和させることができます。シャードを完全に飽和させる代わりに調整エラーを減らすには、この設定を低くすることを検討してください。 |
150% |
|
Record TTL (レコード TTL) |
Number (数値) |
配置されるデータレコードの時間制限。この制限内に正常に配置されなかったレコードは失敗します。この値を設定するときは、データレコードが Amazon Kinesis Producer Library (KPL) から脱退した後も、ネットワークレイテンシーが発生することを考慮してください。 |
30 |
|
Record TTL Unit (レコード TTL 単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Record TTL (レコード TTL)] 値の時間単位。 |
SECONDS (秒) |
|
Thread Pool Size (スレッドプールサイズ) |
Number (数値) |
ネイティブプロセススレッドプールの設定に使用するスレッドの最大数。デフォルト値の 0 を使用すると、KPL プロセスでスレッドプールのサイズを選択できます。 |
0 |
ユーザー指定のアクセスとシークレットキー、および必要に応じてロールを使用して、AWS Kinesis に接続します。これらのログイン情報によって、AWS サービスに送信される要求が安全に署名されます。
名前 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Proxy Configuration (プロキシ設定) |
アウトバウンド接続のプロキシ接続設定。この設定は、Listener ソースと Checkpoint 操作に適用されます。Put Record 操作には影響しません。 |
|||
TLS Configuration (TLS 設定) |
通信に使用するプロトコル。HTTPS プロトコルを使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーは |
HTTP |
||
Access Key (アクセスキー) |
String (文字列) |
Amazon が提供するアクセスキー。 |
x |
|
Secret Key (シークレットキー) |
String (文字列) |
Amazon が提供するシークレットキー。 |
x |
|
Region Endpoint (リージョンエンドポイント) |
String (文字列) |
トピックリージョンエンドポイント。 |
us-east-1 |
|
Role (ロール) |
ロール設定。 |
|||
Connection Timeout (接続タイムアウト) |
Number (数値) |
接続が失敗した場合に例外をスローする前に、コネクタと Amazon Kinesis サーバー間の TCP 接続を最初に確立するときに待機する時間。 |
30 |
|
Connection Timeout Time Unit (接続タイムアウト時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Connection Timeout (接続タイムアウト)] 項目の時間単位。 |
SECONDS (秒) |
|
Response Timeout (応答タイムアウト) |
Number (数値) |
HTTP 要求が送信されてから応答が受信されるまでの最大待機時間。 |
30 |
|
Response Timeout Unit (応答タイムアウト単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Response Timeout (応答タイムアウト)] 値の時間単位。 |
SECONDS (秒) |
|
Reconnection (再接続) |
アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。 |
<kinesis:checkpoint>
Amazon DynamoDB テーブル内のリスナーの操作チェックポイント位置。フェールオーバー時に、コネクタはチェックポイント位置の後にあるレコードのフェッチを開始します。Checkpoint 操作では、リスナーの現在の位置は変更されません。
名前 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Stream Name (ストリーム名) |
String (文字列) |
ストリーム名。 |
x |
|
Application Name (アプリケーション名) |
String (文字列) |
現在のストリーム位置に関するデータを保持する DynamoDB テーブルの名前。 |
x |
|
Shard ID (シャード ID) |
String (文字列) |
シャード識別子。 |
||
Sequence Number (連番) |
String (文字列) |
シャード内のチェックポイントを示す連番。 |
||
Subsequence Number (サブシーケンス番号) |
Number (数値) |
シャード内のチェックポイントを示すサブシーケンス番号。 |
||
Config Ref (設定参照) |
ConfigurationProvider |
このコンポーネントを実行するために使用する設定の名前。 |
x |
KINESIS:ILLEGAL_STATE
KINESIS:INVALID_ARGUMENT
KINESIS:PROVISIONED_THROUGHPUT_EXCEEDED
KINESIS:TIMEOUT
KINESIS:UNAUTHORIZED
<kinesis:put-record>
データレコードを Amazon Kinesis データストリームに配置します。
名前 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Stream Name (ストリーム名) |
String (文字列) |
ストリーム名。 |
x |
|
Partition Key (パーティションキー) |
String (文字列) |
パーティションキー。指定されていない場合、コネクタによってこの値の UUID が生成されます。 |
||
Explicit Hash Key (明示的ハッシュキー) |
String (文字列) |
Amazon Kinesis Data Streams の explicitHashKey 値を上書きします。この値は通常、データレコードパーティションキーの MD5 関数を使用して計算されます。 |
||
Data (データ) |
Any (任意) |
Amazon Kinesis データストリームに配置するコンテンツ。このコンテンツの最大サイズは 1 MB です。 |
#[payload] |
|
Config Ref (設定参照) |
ConfigurationProvider |
このコンポーネントを実行するために使用する設定の名前。 |
x |
|
Streaming Strategy (ストリーミング戦略) |
|
反復可能ストリーム機能を無効にして反復不可能ストリームを使用します。これにより、パフォーマンスオーバーヘッド、メモリ使用量、およびコストが抑えられます。 |
||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前。 |
||
Target Value (対象値) |
String (文字列) |
操作の出力を評価する式。式の結果は対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
型 |
Any (任意) |
KINESIS:CONNECTIVITY
KINESIS:INVALID_ARGUMENT
KINESIS:PROCESSING
KINESIS:RETRY_EXHAUSTED
KINESIS:TIMEOUT
KINESIS:UNAUTHORIZED
<kinesis:listener>
Amazon Kinesis Client Library (KCL) を使用して、ストリーム内の指定されたポイントからリスンします。
バッチサイズはさまざまであるため、チェックポイントが誤った順序で発生する可能性があり、場合によってはトランザクションの損失につながる可能性があります。トランザクションが順番に処理されるようにするには、maxConcurrency=1 を設定します。
|
名前 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Output Mime Type (出力 MIME タイプ) |
String (文字列) |
この操作で出力されるペイロードの MIME タイプ。 |
||
Output Encoding (出力エンコード) |
String (文字列) |
この操作で出力されるペイロードのエンコード。 |
||
Config Ref (設定参照) |
ConfigurationProvider |
このコンポーネントを実行するために使用する設定の名前。 |
x |
|
Primary Node Only (プライマリノードのみ) |
Boolean (ブール) |
クラスターでの実行時のみ、このリスナーをプライマリノード上で実行するかどうか。 |
||
On Capacity Overload (容量過負荷時) |
Enumeration (列挙)。次のいずれかになります。
|
フローが処理できる数以上のメッセージを受信した場合に Mule が適用する戦略。 |
WAIT |
|
Redelivery Policy (再配信ポリシー) |
メッセージの再配信を処理するためのポリシー。 |
|||
Stream Name (ストリーム名) |
String (文字列) |
ストリーム名。 |
x |
|
Application Name (アプリケーション名) |
String (文字列) |
現在のストリーム位置に関するデータを保持する DynamoDB テーブルの名前。テーブルが存在しない場合、コネクタによって初期位置に新しいテーブルが作成されます。 |
x |
|
Shard Configs (シャード設定) |
シャード設定。指定した場合、リスナーは選択したシャードからのみリスンします。 |
|||
Max Batch Size (最大バッチサイズ) |
Number (数値) |
バッチに含めることができるデータレコードの最大数。バッチとは、リスナーがストリームから受信するレコードの数です。 |
10000 |
|
Max Leases For Worker (ワーカーの最大リース数) |
Number (数値) |
リスナーが並行してサブスクライブできるシャードの数。 |
2137483647 |
|
Shard Prioritization (シャード優先度設定) |
Enumeration (列挙)。次のいずれかになります。
|
実行前にシャードの優先度設定や絞り込みを行うために使用するロジック。
NO_OP_SHARD_PRIORITIZATION シャードの元のリストを変更せずに返します。 |
NO_OP_SHARD_PRIORITIZATION |
|
Max Depth (最大深度) |
Number (数値) |
PARENTS_FIRST_SHARD_PRIORITIZATION シャード優先度設定オプションで使用されます。この値より深いシャードは処理から除外されます。 |
||
Read Capacity Units (読み取り容量単位) |
Number (数値) |
Amazon DynamoDB が ThrottlingException を返す前にコンシュームされる 1 秒あたりの厳密な一貫性読み取りの最大数。 |
10 |
|
Write Capacity Units (書き込み容量単位) |
Number (数値) |
Amazon DynamoDB が ThrottlingException を返す前にコンシュームされる 1 秒あたりの書き込みの最大数。 |
10 |
|
Failover Time (フェールオーバー時間) |
Number (数値) |
ワーカーのリースの期間。このパラメーターによって、ワーカーで処理する新しいリースが検索される頻度も決まります。頻度は指定された値の約 2 倍です。 |
10 |
|
Failover Time Unit (フェールオーバー時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Failover Time (フェールオーバー時間)] 項目の時間単位。 |
SECONDS (秒) |
|
Checkpoint On Complete (完了時のチェックポイント) |
Boolean (ブール) |
|
true |
|
Absolute Position (絶対位置) |
Enumeration (列挙)。次のいずれかになります。
|
リスナーが最新のデータレコードまたは最も古いデータレコードのどちらからリスンするか。 |
||
Timestamp (タイムスタンプ) |
DateTime |
リスナーがリスンする日時。 |
||
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
型 |
[Record Attributes (レコード属性)] でのバイナリメッセージの配列。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Host (ホスト) |
String (文字列) |
プロキシ要求が送信されるホスト。 |
x |
|
Port (ポート) |
Number (数値) |
プロキシ要求が送信されるポート。 |
x |
|
Username (ユーザー名) |
String (文字列) |
プロキシに対して認証するユーザー名。 |
||
Password (パスワード) |
String (文字列) |
プロキシに対して認証するパスワード。 |
||
Non Proxy Hosts (非プロキシホスト) |
Array of String (文字列の配列) |
プロキシを使用してはならないホストのリスト。 |
||
Ntlm Domain (NTLM ドメイン) |
String (文字列) |
プロキシに対して認証するドメイン。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Enabled Protocols (有効化されたプロトコル) |
String (文字列) |
このコンテキストで有効化されたプロトコルのカンマ区切りリスト。 |
||
Enabled Cipher Suites (有効化された暗号化スイート) |
String (文字列) |
このコンテキストで有効化された暗号化スイートのカンマ区切りリスト。 |
||
Trust Store (トラストストア) |
||||
Key Store (キーストア) |
||||
Revocation Check (取り消し確認) |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Path (パス) |
String (文字列) |
トラストストアの場所 (可能な場合、現在のクラスパスおよびファイルシステムに対して相対的に解決される場所)。 |
||
Password (パスワード) |
String (文字列) |
トラストストアを保護するために使用するパスワード。 |
||
Type (型) |
String (文字列) |
使用するストアの型。 |
||
Algorithm (アルゴリズム) |
String (文字列) |
トラストストアで使用するアルゴリズム。 |
||
Insecure (安全ではない) |
Boolean (ブール) |
|
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Path (パス) |
String (文字列) |
キーストアの場所 (可能な場合、現在のクラスパスおよびファイルシステムに対して相対的に解決される場所)。 |
||
Type (型) |
String (文字列) |
使用するストアの型。 |
||
Alias (別名) |
String (文字列) |
キーストアに多数の非公開キーがある場合、この属性は、使用するキーの別名を示します。定義しない場合、ファイルにある最初のキーがデフォルトで使用されます。 |
||
Key Password (キーパスワード) |
String (文字列) |
非公開キーを保護するために使用するパスワード。 |
||
Password (パスワード) |
String (文字列) |
キーストアを保護するために使用するパスワード。 |
||
Algorithm (アルゴリズム) |
String (文字列) |
キーストアで使用するアルゴリズム。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Only End Entities (最後のエンティティのみ) |
Boolean (ブール) |
証明書チェーンの最後の要素のみを確認します。 |
||
Prefer Crls (CRL を優先) |
Boolean (ブール) |
最初に OCSP ではなく CRL を試みます。 |
||
No Fallback (代替なし) |
Boolean (ブール) |
第 2 の確認方法を使用しません。 |
||
Soft Fail (ソフトフェール) |
Boolean (ブール) |
取り消しサーバーに到達できない場合や取り消しサーバーが混雑している場合に認定エラーを回避します。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Url |
String (文字列) |
OCSP レスポンダーの URL。 |
||
Cert Alias (証明書の別名) |
String (文字列) |
(トラストストアに含まれている) OCSP 応答の署名証明書の別名 (存在する場合)。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Path (パス) |
String (文字列) |
CRL ファイルへのパス。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Arn |
String (文字列) |
前提とするロールの Amazon リソース名 (ARN)。 |
x |
|
External Id (外部 ID) |
String (文字列) |
別のアカウントのロールを前提とするときに必要な可能性がある一意の識別子。ロールが属するアカウントの管理者が外部 ID を提供している場合、この項目にその値を入力します。 |
||
Duration (所要時間) |
Number (数値) |
ロールセッションの期間。 |
3600 |
|
Duration Time Unit (期間の時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Duration (所要時間)] 項目の時間単位。 |
SECONDS (秒) |
|
Referred Policy Arns (参照されるポリシー ARN) |
Array of String (文字列の配列) |
管理セッションポリシーとして使用する IAM 管理ポリシーの Amazon リソース名 (ARN)。 ポリシーは、ロールと同じアカウントに存在する必要があります。 |
||
タグ |
Object (オブジェクト) |
渡すセッションタグのリスト。各セッションタグは、キー名および関連する値で構成されます。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Fails Deployment (デプロイに失敗) |
Boolean (ブール) |
アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。 |
||
Reconnection Strategy (再接続戦略) |
使用する再接続戦略。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Frequency (頻度) |
Number (数値) |
再接続する頻度 (ミリ秒)。 |
||
Count (数) |
Number (数値) |
再接続の試行回数。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Frequency (頻度) |
Number (数値) |
再接続する頻度 (ミリ秒)。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Aggregated (集約済み) |
Boolean (ブール) |
|||
おおよその到着タイムスタンプ。 |
String (文字列) |
|||
Encryption Type (暗号化種別) |
String (文字列) |
|||
Partition Key (パーティションキー) |
String (文字列) |
|||
Partition Key (パーティションキー) |
String (文字列) |
|||
Sequence Number (連番) |
String (文字列) |
|||
Shard Id (シャード ID) |
String (文字列) |
|||
Sub Sequence Number (サブシーケンス番号) |
Number (数値) |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Max Redelivery Count (最大再配信数) |
Number (数値) |
プロセス失敗メッセージをトリガーするまでに、正常に処理されないメッセージを再配信できる最大回数。 |
||
Message Digest Algorithm (メッセージダイジェストアルゴリズム) |
String (文字列) |
使用するセキュアハッシュアルゴリズム。 |
SHA-256 |
|
Message Identifier (メッセージ識別子) |
メッセージを識別するために使用される戦略。 |
|||
Object Store (オブジェクトストア) |
ObjectStore |
各メッセージの再配信カウンターが保存されるオブジェクトストア。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Use Secure Hash (セキュアハッシュを使用) |
Boolean (ブール) |
再配信されたメッセージの識別にセキュアハッシュアルゴリズムを使用するかどうか。 |
||
Id Expression (ID 式) |
String (文字列) |
メッセージがいつ再配信されたのかを判断するために使用する 1 つ以上の式。このプロパティは、[Use Secure Hash (セキュアハッシュを使用)] 項目が |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Shard Id (シャード ID) |
String (文字列) |
シャード識別子。 |
x |
|
Shard Initial Position (シャードの初期位置) |
シャードの初期位置。 |
x |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
At Sequence Number (連番の位置) |
String (文字列) |
リスナーは、データストリームのこの位置でリスンを開始します。 |
||
After Sequence Number (連番の後) |
String (文字列) |
リスナーは、データストリームのこの位置の後にリスンを開始します。 |
||
Absolute Position (絶対位置) |
Enumeration (列挙)。次のいずれかになります。
|
リスナーは、値に応じて最新または最も古いレコードからリスンを開始します。 |
||
Timestamp (タイムスタンプ) |
DateTime |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
Initial Buffer Size (初期バッファサイズ) |
Number (数値) |
ストリームをコンシュームしてランダムにアクセスするために割り当てられるメモリ量。ストリームのデータ量がこのバッファサイズを超える場合は、[Buffer Size Increment (バッファサイズ増分)] 値に従って、[Max In Memory Size (最大メモリ内サイズ)] 値を上限としてバッファが拡張されます。 |
||
Buffer Size Increment (バッファサイズ増分) |
Number (数値) |
バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を 0 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、 |
||
Max Buffer Size (最大バッファサイズ) |
Number (数値) |
使用するメモリの最大量。これを超えると、 |
||
Buffer Unit (バッファ単位) |
Enumeration (列挙)。次のいずれかになります。
|
この表内の項目が表現される単位。 |
項目 | 型 | 説明 | デフォルト値 | 必須 |
---|---|---|---|---|
In Memory Size (メモリ内サイズ) |
Number (数値) |
データをメモリ内に保持するためにストリームで使用する最大メモリ。これを超えると、ディスクのコンテンツがバッファされます。 |
||
Buffer Unit (バッファ単位) |
Enumeration (列挙)。次のいずれかになります。
|
[In Memory Size (メモリ内サイズ)] 値で表される単位。 |