HOWTO configure a topology to write logs in ceph archive
Why do that¶
The first typical use case of PunchPlatform Archiving system is to store a large amount of logs (typically years of logs) for later potential extraction/replay.
The main idea is to read data from a Kafka broker (which is the usual interface on PunchPlatform) and to write it on an archiving system (a Ceph cluster or a FileSystem - in file-system mode or object-storage mode, it doesn't matter for the moment).
You need a topology injecting data in your Kafka broker. We assume you are be familiar with this.
What to do¶
Suppose we want to inject myTenant data from a Kafka topic myTopic in a Ceph cluster named myCluster, without ciphering. You need a topology with a Kafka spout and a file bolt.
1- Configure your Kafka Spout :
Because the file bolt writes batches of data (instead of single logs), your kafka spout has to be configured in
batched<KafkaInput>mode (batch _size > 0).
Configure batch _size and batch _interval carefully : it sets size of batches, in term of number of events and of duration.
Configure the source topic name to myTopic
Declare the fields you want to archive (typically log, raw _log, local _uuid and local _timestamp).
2- Configure your FileBolt - Configure the File bolt with the following Bolt_settings
The pool name you choose must exist in your Ceph cluster. The
pool is not automatically created during channel launching, it
is created during PunchPlatform deployment and must be
explicitly declared (see deployment settings description
3- Start your topology (in foreground or in a real channel)
4- Check archive status by calling a
storectl list-topics --device-address ceph_configuration:///etc/ceph/myCluster.conf --pool myTenant-data --details
If there is no result, be patient. According to the Kafka Spout batch _size and batch _interval parameters that you defined earlier, you may wait some time before effective writing in archives.
5- Check archived data content by calling another
PunchPlatform command<ObjectStorageOperationTips> (adapt from-date and to-date parameters):
mkdir /tmp/extracted-data storectl dump-topic --device-address ceph_configuration:///etc/ceph/myCluster.conf --pool myTenant-data --topic myTopic --from-date 2016-12-12T03:04:05+01:00 --to-date 2016-12-19T03:04:05+01:00 --into /tmp/extracted-data