Also published the same day: Ruby Kaigi 2018 Talk - Past, present and future of data processing with Ruby
When writing a Kiba ETL job, you may find desirable to get some form of feedback from the job, such as:
- Some metrics telling what the job did (e.g. count of inserted/updated records).
- A list of values which it didn’t manage to map correctly.
- A list of primary keys.
A concrete example: counting source records
Let’s imagine we have a CSV-reading source job.
Legacy mode (Kiba v1)
With Kiba v1 you would have written your job as an
which you would then have run with
bundle exec kiba my_job.etl.
This provides limited abilities to get output, via logging, some form of file writing, or writing to STDOUT, but that’s all.
Kiba API (Kiba v2)
To provide a richer & more flexible integration, you can use the Kiba API and write your Kiba job as a “regular” Ruby class:
which you can run programmatically (e.g. in a Rake task, but it could also be inside a Sidekiq job), with:
At this point you still do not get any feedback, but we can pass a Hash variable to let the job aggregate statistics:
which you can invoke with:
This will work nicely when you need to provide visual feedback to a user, for instance, or trigger emails as a result of specific outcome.
Going further with Ruby lambda hooks
Let’s imagine you need to gather statistics in a Kiba destination. You can leverage Ruby lambdas to do so, like this:
This provides a generic hook to instrument the destination:
As you see, passing a simple Hash around then writing components to manipulate it provides many ways to get feedback from Kiba jobs, be it in real life (e.g. providing user with feedback) or when you write tests.
Thank you for sharing this article!