IBM Streams Internet protocol integration
Project description
Overview
Provides functions to run HTTP requests.
This package exposes the com.ibm.streamsx.inet toolkit as Python methods for use with Streaming Analytics service on IBM Cloud and IBM Streams including IBM Cloud Pak for Data.
Sample
A simple example of a Streams application that emits http requests:
from streamsx.topology.topology import * from streamsx.topology.schema import CommonSchema, StreamSchema from streamsx.topology.context import submit import streamsx.inet as inet topo = Topology() # HTTP GET REQUEST s1 = topo.source(['http://httpbin.org/get']).as_string() result_http_get = inet.request_get(s1) result_http_get.print() # HTTP PUT REQUEST s2 = topo.source(['hello world']).as_string() result_http_put = inet.request_put(s2, url='http://httpbin.org/put', content_type='text/plain') result_http_put.print() submit('STREAMING_ANALYTICS_SERVICE', topo) # Use for IBM Streams including IBM Cloud Pak for Data # submit ('DISTRIBUTED', topo)
Documentation
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
streamsx.inet-1.1.1.tar.gz
(4.6 kB
view hashes)
Built Distribution
Close
Hashes for streamsx.inet-1.1.1-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1ecf648e2f8f6f6460141d2fa0d892abffe37aaaee8dd1f0108c9e04a199937b |
|
MD5 | 35a6e7b907089bdbb5f20b8f9690ca1f |
|
BLAKE2b-256 | fc8e18aa77d012fe359c22f7f9119dcf437162ed2ca8850895b996729217d647 |