The com.ibm.streamsx.objectstorage toolkit provides primitive operators and native functions for reading and writing data from and to Object Storage. This toolkit supports S3 compatible Object Storages and allows developers to write IBM Streams application that interacts with IBM Cloud Object Storage.
Find the full documentation here.
You'll need:
- An instance of IBM COS.
- An API key from IBM Cloud Identity and Access Management with at least
Writerpermissions. - The ID of the instance of COS that you are working with.
- Token acquisition endpoint
- Service endpoint
These values can be found in the IBM Cloud UI by generating a 'service credential' and these credentials shall be stored in an IBM Streams instance application configuration property.
This toolkit is compatible with the Streaming Analytics service on IBM Cloud.
There is a python package available, that exposes SPL operators in the com.ibm.streamsx.objectstorage toolkit as Python methods.
Event Streams --> COS Demo