Skip to main content

Hi,

How do we extract all the pipeline names authored and jobs commited  by an user from Control HUB? 

Regards, Anirban

You can do this with the StreamSets SDK for Python. For the 3.x line:

from streamsets.sdk import ControlHub

control_hub = ControlHub(<server url>, <user id>, <password>)
pipelines = control_hub.pipelines.get_all(committer=<user id of the committer>)
jobs = control_hub.jobs.get_all(created_by=<user id of the creator>)

The code is identical using the beta version of the DataOps Platform SDK for Python with the exception of needing to pass in a credential ID and token rather than user ID and password.

Reply


Terms & Conditions