You'll need:
- An instance of IBM COS
- An instance of IBM Event Streams
- An instance of IBM Streaming Analytics
- An instance of IBM SQL Query
Service plans for performance use case: To achieve with large data volumes high throughput (Streaming Analytics) and guaranteed performance (Event Streams) it is required to select the following service plans:
- Enterprise plan for Event Streams*
- Premium Container for Streaming Analytics*
- Standard plan for IBM Cloud Object Storage*
- Select the same region for the services, for example,
us-south
* Not free of charge, see pricing for the service plan
For IBM SQL Query service the lite plan is sufficient.
Generate and get the credentials:
These credentials shall be stored in IBM Streaming Analytics service instance application configuration properties.
Setup the Message Hub toolkit operators:
app option name = messagehub
property name = messagehub.creds
Put the entire JSON string into the property value.
Setup the Objectstorage toolkit operators:
app option name = cos
property name = cos.creds
Put the entire JSON string into the property value.
When running the "performance" scenario, it is recommended to create a topic wiht 6 partitions.
topic name = dh
partitions = 6
Create a bucket with a unique bucket name, for example dh-demo001
, cross-region
for location: us-geo
with Standard
Storage class.
Select regions and endpoints: IBM Cloud Object Storage Endpoints
- Download streamsx.messagehub toolkit. For this demo at least version 1.5 is required. You need to build the toolkit, if no pre-built release is available.
- Download streamsx.objectstorage toolkit. For this demo at least version 1.6 is required. You need to build the toolkit, if no pre-built release is available.
The toolkits containing the demo applications needs to be indexed before launching them with streamsx-runner
cd streamsx.objectstorage/demo/data.historian.event.streams.cos.exactly.once.semantics.demo
make tkidx
After this toolkit.xml files in dh_generate_json
and dh_json_parquet
directories have been generated.
Ensure that you have Python 3.5 or later installed. For example, you can get Python 3.5 from the Anaconda archive page.
Ensure that the bin directory is added to the PATH environment variable. If necessary, add the bin directory by entering the following command on the command line:
export PATH="~/anaconda3/bin:$PATH"
pip install streamsx
Ensure that you have set the following environment variables for testing with Streaming Analytics service in IBM Cloud:
STREAMING_ANALYTICS_SERVICE_NAME
- name of your Streaming Analytics serviceVCAP_SERVICES
- VCAP information in JSON format or a JSON file