XML をリアルタイムで生成するデータ ソースがあります。この XML のリアルタイム分析のために kinesis エージェントを使用して Kinesis Firehose 統合をチェックしているときに、Kinesis エージェントがソース ファイルの各行を 1 つのレコードと見なしていることがわかりました。たとえば、Kinesis は指定されたサンプル XML で 6 つのレコードを検出しました
<note>
<to>Tove</to>
<from>Jani</from>
<heading>Reminder</heading>
<body>Don't forget me this weekend!</body>
</note>
ここで、ラムダを使用して入力 XML に対してデータ変換を実行する必要があるとします。キネシス エージェントは XML の構造を見落としているため、どうすればよいですか?
参照する Kinesis エージェントのログは次のとおりです。
2020-07-08 02:38:03.955+0000 (FileTailer[fh:POCKinesis:/var/log/cadabra_xml/*.xml].MetricsEmitter RUNNING) com.amazon.kinesis.streaming.agent.tailing.FileTailer [INFO] FileTailer[fh:POCKinesis:/var/log/cadabra_xml/*.xml]: Tailer Progress: Tailer has parsed 6 records (236 bytes), transformed 0 records, skipped 0 records, and has successfully sent 6 records to destination.
2020-07-08 02:38:03.957+0000 (Agent.MetricsEmitter RUNNING) com.amazon.kinesis.streaming.agent.Agent [INFO] Agent: Progress: 6 records parsed (236 bytes), and 6 records sent successfully to destinations. Uptime: 870056ms