データ取り込みおよびレプリケーションの基本操作 > データ取り込みおよびレプリケーションの基本操作 > Secure Agentサービス
  

Secure Agentサービス

Secure Agentサービスは、Secure Agentがデータ処理に使用するプラガブルマイクロサービスです。各Secure Agentサービスは、エージェントで実行されている他のサービスとは独立して実行されます。
独立したサービスアーキテクチャには、次の利点があります。
Secure Agentで実行されるジョブは、ライセンスと組織で使用されているInformatica Intelligent Cloud Servicesによって異なります。データ取り込みおよびレプリケーションでは、次のSecure Agentサービスを利用できます。
各サービスには、固有の設定プロパティのセットがあります。パフォーマンスを最適化するため、またはInformaticaグローバルカスタマサポートから指示された場合は、サービスを設定したり、サービスのプロパティを変更しなければならないことがあります。

データベース取り込みサービス

アプリケーション取り込みとレプリケーションデータベース取り込みとレプリケーションはどちらも、データベース取り込みエージェントサービスを使用してジョブを実行します。
Secure Agentをランタイム環境にダウンロードしてデータベース取り込みサービスを有効にすると、Secure Agentが実行されているオンプレミスのシステムにデータベース取り込みパッケージがプッシュされます。その後、必要に応じてSecure Agentで実行されるデータベース取り込みサービスのプロパティを設定できます。

データベース取り込みサービスのプロパティ

Secure Agentグループが使用するデータベース取り込みサービスの動作を変更または最適化するために、ランタイム環境のデータベース取り込みエージェント設定プロパティを設定できます。
プロパティを設定するには、ランタイム環境のSecure Agentを開き、[編集]をクリックします。[システム構成の詳細]または[カスタム構成の詳細]で、サービスとして[データベース取り込み]、タイプとして[DBMI_AGENT_CONFIG]を選択します。
次の表に、データベース取り込みエージェントサービスのプロパティを示します。
プロパティ
説明
maxTaskUnits
Secure Agentが実行されているオンプレミスマシンで同時に実行できるアプリケーション取り込みとレプリケーションタスクユニットとデータベース取り込みとレプリケーションタスクユニットの最大数。
タスクユニットは、ハードウェアまたはソフトウェアの容量や可用性とは関係がありません。maxTaskUnitsを設定すると、CPU使用率を正確に制御できます。有効な値は1-2000000000(20億)です。
Secure Agentマシンの適切なタスクユニット数を計算するには、コア数を3または4で割ることをお勧めします。例えば、8コアのマシンを使用している場合は、このプロパティを2に設定できます。その後、CPU使用率を監視し、必要に応じてプロパティ値を調整してパフォーマンスチューニングを行います。
初期ロード処理中、このプロパティは同時にアンロードできるテーブルの数を決定します。残りのテーブルはキューに入れられ、リソースが使用可能になるとアンロード処理を開始します。
注: 1つのジョブで多くのテーブルを処理できます。処理できるテーブルの総数の制限となるのは、使用可能なメモリのみです。1KBの行サイズに基づく初期ロードタスクには、平均してテーブルごとに25MBのRAMが必要です。
増分ロード処理中、このプロパティは同時に実行できるアプリケーション取り込みとレプリケーションジョブとデータベース取り込みとレプリケーションジョブの数を決定します。
このプロパティをSecure Agentマシンのコア数よりも大きい値に設定すると、タスク実行の並列処理が増える可能性がありますが、タスク実行時にパフォーマンスのボトルネックが発生する可能性もあります。
serviceLogRetentionPeriod
最終更新がファイルに書き込まれた後に、各内部データベース取り込みサービスログファイルが保持される日数。この保持期間が経過すると、ログファイルは削除されます。デフォルト値は7日です。
サービスログは、それらが作成されたSecure Agentホスト(<infaagent>/apps/Database_Ingestion/logs)に保持されます。
注: このプロパティは、アプリケーション取り込みとレプリケーションデータベース取り込みとレプリケーションの両方に適用されます。
taskLogRetentionPeriod
最終更新がジョブログファイルに書き込まれた後、各ジョブログファイルを保存する日数。この保持期間が経過すると、ログファイルは削除されます。デフォルト値は7日です。
ociPath
Oracleソースおよびターゲットの場合、oci.dllまたはlibcIntsh.soファイルが含まれるOracle Call Interface(OCI)ディレクトリへのパス。デフォルトでは、Oracleは、$ORACLE_HOME/lib(Linuxの場合)または%ORACLE_HOME%\bin(Windowsの場合)を使用します。OCIライブラリは、データベース取り込みCDCタスクによってOracleに接続するために使用されます。
実行中のDBMIエージェントの場合、この値はWindowsのPATH環境変数の値、またはLinuxのLD_LIBRARY_PATH環境変数の値に付加されます。PATHまたはLD_LIBRARY_PATH環境変数にすでにOCIパスが含まれている場合、このプロパティは必要ありません。
注: このプロパティはデータベース取り込みとレプリケーションにのみ適用されます。
serviceUrl
データベース取り込みサービスがInformatica Intelligent Cloud Servicesクラウドへの接続に使用するURL。
注: このプロパティは、アプリケーション取り込みとレプリケーションデータベース取り込みとレプリケーションの両方に適用されます。
logLevel
データベース取り込みサービスが生成するログに含める詳細レベル。次のオプションがあります。
  • - トレース
  • - デバッグ
  • - 情報
  • - 警告
  • - エラー
デフォルト値はトレースです。
注: このプロパティは、アプリケーション取り込みとレプリケーションデータベース取り込みとレプリケーションの両方に適用されます。
taskExecutionHeapSize
タスク実行サービスの最大ヒープサイズ(ギガバイト単位)。このプロパティには、実行されるすべてのアプリケーション取り込みとレプリケーション、およびデータベース取り込みとレプリケーションのタスクをホストする単一のJavaプロセスに渡される値が含まれます。多数のタスクを実行している場合や大量のデータを処理している場合、taskExecutionHeapSizeを増やすことが必要になることがあります。このプロパティ値の後に、ギガバイトの場合は「g」と入力します(例: 「9g」)。デフォルト値は「8g」です。
注: このプロパティは、アプリケーション取り込みとレプリケーションデータベース取り込みとレプリケーションの両方に適用されます。
useProxy
このプロパティをtrueに設定すると、ターゲットへの接続時およびターゲットへのデータの書き込み時にDBMIエージェントがプロキシを通過できるようになります。次に、DBMIエージェントは、Secure Agentプロキシ構成のプロキシ設定を使用します。デフォルトでは、プロキシ設定は使用されません。
注: このプロパティは、アプリケーション取り込みとレプリケーションデータベース取り込みとレプリケーションの両方に適用されます。
intermediateStorageDirectory
増分ロードジョブおよび初期ロードと増分ロードの組み合わせジョブの場合、関連するタスク定義で[永続ストレージの有効化]オプションが選択されているときに、データを含む中間ファイルが保存されるローカルルートディレクトリです。
注: このプロパティはデータベース取り込みとレプリケーションにのみ適用されます。
storageBackupDirectory
増分ロードジョブおよび初期ロードと増分ロードの組み合わせジョブの場合、関連するタスク定義で[永続ストレージの有効化]オプションが選択されているときに、バックアップファイルが保存されるディレクトリへのパスです。
注: このプロパティはデータベース取り込みとレプリケーションにのみ適用されます。
storageProperties
増分ロードジョブおよび初期ロードと増分ロードの組み合わせジョブの場合、関連するタスク定義で[永続ストレージの有効化]オプションが選択されているときに使用されるキー=値のペアのカンマ区切りリストです。このプロパティを指定する場合は、Informaticaグローバルカスタマサポートにお問い合わせください。
注: このプロパティはデータベース取り込みとレプリケーションにのみ適用されます。
supportedLoadTypes
アプリケーション取り込みとレプリケーションジョブ、およびデータベース取り込みとレプリケーションジョブの場合に、データベース取り込みエージェントサービスが処理できる負荷のタイプ。次の値を1つ以上、カンマ(,)で区切って入力することができます。
  • - INITIAL。初期ロードジョブ、または初期ロードと増分ロードの組み合わせジョブの初期ロードフェーズ。
  • - INCREMENTAL。増分ロードジョブ、または初期ロードと増分ロードの組み合わせジョブの増分フェーズで、ターゲットに書き込みます。
  • - INCREMENTAL_STAGING。増分ロードまたは組み合わせロードジョブのCDCステージングタスク。
デフォルトはINITIAL,INCREMENTAL,INCREMENTAL_STAGINGで、これはすべてのロードタイプを示します。
注: 複数のデータベース取り込みエージェントが同じロードタイプをサポートするように設定されている場合、ジョブは使用可能なタスクユニットが最も多いエージェントを使用します。

データベース取り込みエージェントの環境変数

データベース取り込みエージェントサービスの動作を変更または最適化するために、次の環境変数を定義できます。
環境変数を設定するには、ランタイム環境のSecure Agentを開き、[編集]をクリックします。[システム構成の詳細]または[カスタム構成の詳細]で、サービスとして[データベース取り込み]、タイプとして[DBMI_AGENT_ENV]を選択します。
環境変数
説明
DBMI_REPLACE_UNSUPPORTED_CHARS
Microsoft Azure Synapse Analyticsターゲットの場合に、アプリケーション取り込みとレプリケーションジョブまたはデータベース取り込みとレプリケーションジョブが、ターゲットが正しく処理できない文字データ内の文字を置き換えるかどうかを指定します。文字の置き換えを有効にするには、この環境変数をtrueに設定します。
DBMI_REPLACE_UNSUPPORTED_CHARS=true
設定後、アプリケーション取り込みとレプリケーションまたはデータベース取り込みとレプリケーションは、DBMI_UNSUPPORTED_CHARS_REPLACEMENT環境変数に指定されている文字を使用して、サポートされていない文字を置き換えます。
DBMI_UNSUPPORTED_CHARS_REPLACEMENT
DBMI_REPLACE_UNSUPPORTED_CHARS環境変数がtrueに設定されている場合に、Microsoft Azure Synapse Analyticsターゲットが正しく処理できないソースデータ内の文字を置き換える文字を指定します。
デフォルト値: ? (疑問符)
注: この環境変数はデータベース取り込みとレプリケーションに対してのみ定義します。
DBMI_WRITER_CONN_POOL_SIZE
アプリケーション取り込みとレプリケーションジョブまたはデータベース取り込みとレプリケーションジョブが変更データをターゲットにプロパゲートするために使用する接続の数を示します。デフォルト値は8です。有効な値は4~8です。
DBMI_WRITER_RETRIES_MAX_COUNT
データベース取り込みとレプリケーションジョブがソースデータをAmazon S3またはMicrosoft Azure Data Lake Storage Gen2ターゲットにロードしている最中にネットワークの問題が発生した場合に、ジョブで初期ロードまたは増分ロードを続行する要求を再試行する最大回数を指定します。再試行がすべて失敗した場合、ジョブは失敗となります。
デフォルト値は5です。
DBMI_WRITER_RETRIES_INTERVAL_IN_MILLIS
ネットワークで問題が発生した場合に、データベース取り込みとレプリケーションジョブがAmazon S3またはMicrosoft Azure Data Lake Storage Gen2ターゲットへの初期ロードまたは増分ロードを続行する要求を再試行する前に待機する間隔(ミリ秒単位)を指定します。
デフォルト値は1000です。
注: 環境変数を定義または変更したら、データベース取り込みエージェントを再起動して、変更を有効にします。

ローカルタスクの設定プロパティ

CDCステージングタスクなど、別のローカルプロセスとして実行されるタスクに対して、ローカルタスクの設定プロパティを設定できます。
ランタイム環境のSecure Agentを開き、[編集]をクリックします。[システム構成の詳細]または[カスタム構成の詳細]で、サービスとして[データベース取り込み]を選択し、タイプとして[LOCAL_TASK_CONFIGG]を選択します。
次の表に、ローカルタスクの設定プロパティを示します。
プロパティ
説明
taskExecutionHeapSize
メモリ割り当てプールの最大ヒープサイズ(ギガバイト単位)。このプロパティには、実行するタスクをホストする1つのJavaプロセスに渡される値が含まれます。この値に続けてギガバイトの場合は「g」と入力します(例: 「3g」)。デフォルト値は「2g」です。
taskStartTimeoutSeconds
タスクの起動がタイムアウトするまでの期間(秒単位)。この時間が経過すると、エラーが発生します。デフォルト値は120です。

一括取り込み(ファイル)

Secure Agentグループが使用するファイル取り込みとレプリケーションの動作を変更または最適化するには、Administratorでランタイム環境の一括取り込みエージェントサービスプロパティを設定します。
以下のプロパティを設定する事ができます。
タイプ
名前
説明
AGENT_RUNTIME_SETTINGS
file-listener-snapshot-dir
新しいファイルリスナコンポーネントのスナップショットが追加されるディレクトリ。次のディレクトリパスを追加できます。
  • - MassIngestionRuntimeディレクトリに対する相対パス。例: ../data/monitor
  • - 絶対パス。以下に例を示します。
  • <Secure agent installation directory>/apps/MassIngestionRuntime/data/monitor
    Secure agent installation directoryにはSecure Agentがインストールされているディレクトリの名前が入ります。
注: グループに複数のSecure Agentが存在する場合は、すべてのエージェントで共有されるスナップショットディレクトリを使用します。
AGENT_RUNTIME_SETTINGS
mi-task-workspace-dir
ファイル取り込みとレプリケーションタスクがファイルをターゲットに転送するときに中間ステージング領域として使用するエージェント内のディレクトリです。エージェント内のカスタムの場所のディレクトリ。このパスは、共有場所、マウントされた場所、およびエージェント内のデフォルトの場所とは異なる場所にすることができます。
AGENT_RUNTIME_SETTINGS
mi-task-project-dir
ファイル取り込みとレプリケーションタスクがプロジェクトファイルを保存するディレクトリ。エージェント内のカスタムの場所のディレクトリ。このパスは、共有場所、マウントされた場所、およびエージェント内のデフォルトの場所とは異なる場所にすることができます。
AGENT_RUNTIME_SETTINGS
mi-task-logs-dir
ファイル取り込みとレプリケーションタスクがタスクログファイルを保存するディレクトリ。エージェント内のカスタムの場所のディレクトリ。このパスは、共有場所、マウントされた場所、およびエージェント内のデフォルトの場所とは異なる場所にすることができます。
AGENT_RUNTIME_SETTINGS
mi-task-quarantine-dir
ウイルススキャンの実行時に検出された感染ファイルをファイル取り込みとレプリケーションタスクが保存するディレクトリ。エージェント内のカスタムの場所のディレクトリ。このパスは、共有場所、マウントされた場所、およびエージェント内のデフォルトの場所とは異なる場所にすることができます。
例: userdata\quarantine
注: 検疫ディレクトリを自動的にクリーンアップするには、検疫場所のエージェントプロパティを/tmp/informatica/fmi/quarantineのようなシステム一時ファイルの場所に設定します。
AGENT_RUNTIME_SETTINGS
agent-dedup-repository
スキップされた重複ファイルに関する情報は、Informatica Intelligent Cloud Services(IICS)に保存されます。スキップされた重複ファイルの情報をSecure Agentに保存するには、プロパティをtrueに設定します。
デフォルトはfalseです。
スキップされた重複に関する情報の保存については、「ファイル取り込みとレプリケーションガイド」を参照してください。
AGENT_RUNTIME_SETTINGS
mi-dedup-snapshot-dir
スキップされた重複ファイルに関する情報をSecure Agentに保存するためのパスを入力します。
agent-dedup-repositoryプロパティがtrueに設定されている場合のみ適用されます。
AGENT_RUNTIME_SETTINGS
file-listener-max-pool-size
ファイルリスナを実行するスレッドの最大数。
デフォルトは20です。
AGENT_RUNTIME_SETTINGS
file-listener-core-pool-size
スレッドの合計数。
デフォルトは20です。
AGENT_RUNTIME_SETTINGS
fmi-task-max-pool-size
ファイル取り込みとレプリケーションタスクを実行するスレッドの最大数。
デフォルトは50です。
AGENT_RUNTIME_SETTINGS
fmi-task-core-pool-size
スレッドの初期数または最小数。
デフォルトは20です。
AGENT_RUNTIME_SETTINGS
ftp-receive-socket-buffer-size
FTPインバウンドパケットのバッファサイズ。
デフォルトは16バイトです。
AGENT_RUNTIME_SETTINGS
ftp-send-socket-buffer-size
FTPアウトバウンドパケットのバッファサイズ。
デフォルトは16バイトです。
AGENT_RUNTIME_SETTINGS
http-client-timeout
Informatica Intelligent Cloud Servicesへのエージェントの要求のタイムアウト時間(秒単位)。
デフォルトは30秒です。
PGP_SETTINGS
public-keyring-path
パブリックキーリングを保存するディレクトリ。次のディレクトリパスを追加できます。
  • - データ取り込みおよびレプリケーションがインストールされるディレクトリに対する相対パス。以下に例を示します。
  • ../data/pubring.pkr
    pubring.pkrにはパブリックキーリングを保存するファイルの名前が入ります。
  • - 絶対パス。以下に例を示します。
  • <Secure agent installation directory>/apps/MassIngestionRuntime/data/pubring.pkr
    pubring.pkrにはパブリックキーリングを保存するファイルの名前が、Secure agent installation directoryにはエージェントがインストールされているディレクトリの名前が入ります。
PGP_SETTINGS
secret-keyring-path
シークレットキーリングを保存するディレクトリ。次のディレクトリパスを追加できます。
  • - データ取り込みおよびレプリケーションがインストールされるディレクトリに対する相対パス。以下に例を示します。
  • ../data/secring.pkr
    secring.pkrにはシークレットキーリングを保存するファイルの名前が入ります。
  • - 絶対パス。以下に例を示します。
  • <Secure agent installation directory>/apps/MassIngestionRuntime/data/secring.pkr
    secring.pkrにはシークレットキーリングを保存するファイルの名前が、Secure Agent installation directoryにはエージェントがインストールされているディレクトリの名前が入ります。
JVM_SETTINGS
app-heap-size
ファイル取り込みとレプリケーションアプリケーションの最小および最大ヒープサイズ。
デフォルトは-Xms256m -Xmx2048mです。
JVM_SETTINGS
lcm-heap-size
ライフサイクル管理スクリプトの最小および最大ヒープサイズ。
デフォルトは-Xms32m -Xmx128mです。
Secure Agentを編集する場合は、[カスタム構成の詳細]領域で次のプロパティを設定できます。
タイプ
名前
説明
AGENT_RUNTIME_SETTINGS
ComplexFileDisableWriteChecksum
crcファイルを無視するには、値をTrueに設定します。ジョブは、Hadoop Files V2をソースとし、Snowflake Cloud Data Warehouse V2をターゲットとして正常に実行されます。
フォルダパスを指定するためのガイドライン
フォルダパスは、共有場所、マウントされた場所、およびSecure Agent内のデフォルトの場所とは異なる場所にすることができます。
次の表に、ソースフォルダパスの前後のスラッシュの使い方を示します。
ソース
フォルダパス
Windows
<フォルダパス>
例: C:\temp
Linux
/<フォルダパス>/
例: /root/path
Windowsの共有の場所
<フォルダパス>にスラッシュ(\)を追加
例えば、パス\\INV12B2B01\Shared\pathは、\\\\INV12B2B01\\Shared\\pathと指定されます

CMIストリーミングエージェント

CMIストリーミングエージェントを使用して、ストリーミング取り込みとレプリケーションタスクを定義し、デプロイします。ストリーミング取り込みとレプリケーションサービスでデータ取り込みおよびレプリケーションタスクを設定します。
CMIストリーミングエージェントは、オンプレミスシステムで実行され、ストリーミング取り込みとレプリケーションと連携して動作します。オンプレミスシステムで、CMIストリーミングエージェントはストリーミング取り込みとレプリケーションでデプロイされたジョブを実行します。エージェントは各ジョブのステータスおよび統計情報を更新します。
Linuxでエージェントのインストールディレクトリ名にスペースが含まれている場合、CMIストリーミングエージェントが起動しません。エージェントは接続タイムアウトステータスを返します。再起動を数回試行した後に、エージェントはエラー状態になります。

CMIストリーミングエージェントのプロパティ

CMIストリーミングエージェントの動作を変更または最適化するには、ランタイム環境でエージェントプロパティを設定します。CMIストリーミングエージェントのプロパティは、Secure Agentの編集時に[システム構成の詳細]領域で設定します。
CMIストリーミングエージェントのエンジン、エージェント、およびスクリプトのプロパティを設定できます。
次の図は、CMIストリーミングエージェントのプロパティの一部を示しています。
ストリーミング取り込みエージェントの設定可能なプロパティの一部を表示します。
CMIストリーミングエージェントの次のプロパティを設定できます。
タイプ
プロパティ名
説明
エンジン
MaxLogFileSize
エンジンが作成可能なログファイルの最大サイズ。
デフォルトは5 MBです。
エンジン
LogLevel
エンジンのログレベル。
エージェント
DataflowPullInterval
エージェントがタスクで更新を確認するまでの間隔。
デフォルトは60秒です。
エージェント
JVM
エージェントのJVMプロパティのリスト。例:[-Xms256M -Xmx256M]
エージェント
LogLevel
エージェントのログレベル。
エージェント
MaxLogFileSize
エージェントが作成可能なログファイルの最大サイズ。
デフォルトは10MBです。
エージェント
MaxNumberOfBackups
エージェントのバックアップログファイルの最大数。
デフォルトは5です。
スクリプト
LogLevel
スクリプトのログレベル。
スクリプト
MaxFileSize
最大ファイルサイズ。この最大ファイルサイズに達した後、ログはロールオーバーされ、新しいファイルが作成されます。
デフォルトは10MBです。
スクリプト
MaxBackupIndex
ロールオーバー後に保持するバックアップファイルの最大数。
デフォルトは5です。

ストリーミングエージェントオフラインモード

CMIストリーミングエージェントがオフラインであるか、インターネットに接続されていない場合、ストリーミング取り込みとレプリケーションジョブを実行および監視できます。
ストリーミングエージェントは、オンラインとオフラインの両方の通信モードをサポートします。オフラインモードでは、ストリーミングエージェントがInformatica Intelligent Cloud Servicesと長期間通信を行っていない場合でも、ストリーミング取り込みとレプリケーションジョブの実行は継続されます。ストリーミングエージェントは、ジョブの正常性と統計をローカルで引き続き監視します。ストリーミングエージェントがオンラインになり、クラウドサービスに接続すると、エージェントとジョブの構成変更が更新され、サービスの正常性と統計が更新されます。
オフラインモードとオンラインモードを切り替えるには、ストリーミング取り込みとレプリケーションサービスによって提供されるコマンドラインユーティリティを使用できます。次のコマンドを実行して、コマンドラインユーティリティを起動します。
<Informatica Secure Agent>/apps/Streaming_Ingestion_Agent/<version>/runcli.bat
コマンドラインユーティリティはコマンドプロンプトinfa/stream>を使用し、3つのグループのコマンドを提供します。
通信モードは、コマンドラインユーティリティを介してのみ変更できます。ストリーミングエージェントは、エージェントが再起動したときに通信モードを保持します。
次の表に、このコマンドラインユーティリティのコマンドを示します。
コマンド
説明
app-config
ストリーミングエージェントアプリケーションの現在の構成を表示します。
infa/stream :>app-config
deploy.pull.interval : 60
health.poll.interval : 30
minifi.ingester.file.location : ./conf
siagent.communication.mode : Online
siagent.monitoring.persist.dir : ../data
siagent.statistics.post.batchsize : 720
siagent.statistics.post.concurrency : 60
siagent.status.persist.dir : ../data
statistics.poll.interval : 30
app-setconfig
このコマンドを使用して、次のプロパティを設定します。
  • - siagent.communication.mode.オフラインまたはオンライン通信モードを設定するために使用します。
  • - siagent.statistics.post.batchsize.バッチ内のスナップショットの数を定義するために使用します。
  • - siagent.statistics.post.concurrency.統計を投稿するワーカースレッドの数を定義するために使用します。
--key--valueトークンはオプションです。
infa/stream :>app-setconfig --key siagent.statistics.post.batchsize --value 20
または
infa/stream :>app-setconfig siagent.statistics.post.batchsize 20
app-status
ストリーミングエージェントの現在のステータスを表示します。
health status codehealth error messageAdministratorに表示されるエージェント(サービス)のステータスを示します。
uptimeはストリーミングエージェントアプリケーションが使用可能になってからの秒数を示します。
infa/stream :>app-status
health error message : No errors
health status code : RUNNING(0)
uptime : 67828
app-statistics
ストリーミングエージェントの全体的な統計収集のメタデータとステータスを表示します。
  • - collection interval。統計収集の間隔(秒単位)。
  • - post interval。投稿された統計または投稿の試みの頻度。
  • - max batch size。1回のhttp投稿で投稿されるスナップショットの最大数。
  • - last batch size。最後のhttp投稿のスナップショットの数。
  • - last time collected。統計が最後に収集されたときのタイムスタンプ。
  • - last time posted。統計が最後に投稿されたときのタイムスタンプ。
infa/stream :>app-statistics
collection interval : 30
last batch size : 2
last time collected : 7/3/20 10:19:03 AM IST
last time posted : 7/3/20 10:18:53 AM IST
max batch size : 20
pending snapshots : 3
post interval : 30
clear
画面をクリアします。
-
exit、quit
アプリケーションを終了します。
-
help
使用可能なすべてのコマンドのサマリを表示します。
infa/stream :>help
AVAILABLE COMMANDSAgent Application Commands
app-config: Show agent application configuration
app-setmode: Set the communication mode [Online/Offline]
app-status: Show agent application statusBuilt-In Commands
clear: Clear the shell screen.
exit, quit: Exit the shell.
help: Display help about available commands.Streaming Ingestion Task Commands
task-health: Show streaming ingestion task health
task-list: Show streaming ingestion task list
task-metadata: Show streaming ingestion task metadata
task-list
ストリーミングエージェントに現在デプロイされているストリーミング取り込みとレプリケーションジョブのリストを表示します。
infa/stream :>task-list
6e61e76f-2618-4292-ab3d-dd181f47ee91
ad5053c7-5ac2-493f-8cbb-a24900b61f71
task-health
ストリーミングエージェントのすべてのストリーミング取り込みとレプリケーションジョブの正常性のステータスを表示します。
--nameオプションまたは--idオプションを使用してジョブを指定します。
何も指定されていない場合は、すべてのジョブのリストが表示されます。
infa/stream :>task-health --name aby_df4
processors : [{"id":"14a7a095-7fac-4fc3-ac5c-705369132516","status":"ERROR"},{"id":"821e6730-3aed-4d3f-b875-45f424b6b963","status":"RUNNING"}]
status : ERROR
timestamp : Sat May 09 06:04:08 IST 2020
infa/stream :>task-health
6e61e76f-2618-4292-ab3d-dd181f47ee91
processors : [{"id":"2a0b8715-aa7a-46c5-9d6a-6a356f5a0102","status":"ERROR"},{"id":"1172f3a8-35dd-41ef-be4b-bc0cf37e3794","status":"RUNNING"}]
status : ERROR
timestamp : Sat May 09 06:04:08 IST 2020
ad5053c7-5ac2-493f-8cbb-a24900b61f71
processors : [{"id":"14a7a095-7fac-4fc3-ac5c-705369132516","status":"ERROR"},{"id":"821e6730-3aed-4d3f-b875-45f424b6b963","status":"RUNNING"}]
status : ERROR
timestamp : Sat May 09 06:04:08 IST 2020
task-metadata
ストリーミングエージェントのすべてのストリーミング取り込みとレプリケーションジョブのメタデータを表示します。
--nameオプションまたは--idオプションを使用してジョブを指定します。
何も指定されていない場合は、すべてのジョブのリストが表示されます。
infa/stream :>task-metadata --name aby_df4
id : ad5053c7-5ac2-493f-8cbb-a24900b61f71
name : aby_df4
runId : 9071 version : 1
infa/stream :>task-metadata
6e61e76f-2618-4292-ab3d-dd181f47ee91
id : 6e61e76f-2618-4292-ab3d-dd181f47ee91
name : aby_df2
runId : 9069
version : 8
ad5053c7-5ac2-493f-8cbb-a24900b61f71
id : ad5053c7-5ac2-493f-8cbb-a24900b61f71
name : aby_df4
runId : 9071
version : 1
task-statistics
ストリーミングエージェントのすべてのストリーミング取り込みとレプリケーションジョブの統計の詳細を表示します。
--nameオプションまたは--idオプションを使用してジョブを指定します。
何も指定されていない場合は、すべてのジョブのリストが表示されます。
infa/stream :>task-statistics --name aby_df1
dataflow name : aby_df1
last time collected : 1590861803731
last time posted : 1590861806091
infa/stream :>task-statistics
7b7d3c09-df43-482f-b6c8-8dd80187e6d7
dataflow name : aby_df2
last time collected : 1590861770731
last time posted : 1590861741132
decfad0a-20df-4226-84f9-1ff1ab6ef96a
dataflow name : aby_df1
last time collected : 1590861768730
last time posted : 1590861771054

オンラインモードからオフラインモードへ

デフォルトでは、ストリーミングエージェントはオンラインモードです。
ストリーミングエージェントをオフラインモードに変更するには、次の手順を実行します。
  1. 1次のコマンドを使用して、コマンドラインユーティリティを起動します。
  2. Windowsの場合:
    <Informatica_Secure_Agent>/apps/Streaming_Ingestion_Agent/<version>/runcli.bat
    UNIXの場合:
    <Informatica_Secure_Agent>/apps/Streaming_Ingestion_Agent/<version>/runcli.sh
  3. 2ストリーミングエージェントをオフラインモードに設定します。
  4. app-setconfig --key siagent.communication.mode --value Offline
  5. または
  6. app-setconfig siagent.communication.mode Offline
    ストリーミングエージェントは、ストリーミング取り込みとレプリケーションジョブの正常性の更新と統計の送信を停止します。

オフラインモードからオンラインモードへ

ストリーミングエージェントをオンラインモードに変更するには、次の手順を実行します。
  1. 1次のコマンドを使用して、コマンドラインユーティリティを起動します。
  2. Windowsの場合:
    <Informatica_Secure_Agent>/apps/Streaming_Ingestion_Agent/<version>/runcli.bat
    UNIXの場合:
    <Informatica_Secure_Agent>/apps/Streaming_Ingestion_Agent/<version>/runcli.sh
  3. 2ストリーミングエージェントをオンラインモードに設定します。
  4. app-setconfig --key siagent.communication.mode --value Online
  5. または
  6. app-setconfig siagent.communication.mode Online
    ストリーミングエージェントは、すべてのストリーミング取り込みとレプリケーションジョブの正常性の更新の送信を開始し、更新が[監視]ページに表示されます。オフライン中に収集された統計バックログを含む、すべてのストリーミング取り込みとレプリケーションジョブの統計をサービスに送信する処理を開始します。また、ストリーミング取り込みとレプリケーションジョブの更新を同期するか、オフラインのときにデプロイされた新しいストリーミング取り込みとレプリケーションジョブをサービスに追加します。