Question

How to get a specific pipeline using pipeline id or pipeline name using python SDK?

  • 5 September 2023
  • 0 replies
  • 11 views

Badge

sch.pipelines.get(pipeline_id='id of pipeline') function can be used to get the specific pipeline using the pipeline id. 

 

from streamsets.sdk import ControlHub

server_url = 'https://cloud.streamsets.com/'

sch = ControlHub(server_url='https://cloud.streamsets.com/',username = 'username@org',password = 'password')

desiredpip=sch1.pipelines.get(pipeline_id='00a2a5e6-5125-4477-b022-5507c7f63c59:dpmsupport')

desiredpip=sch1.pipelines.get(name='SDC500 - Dev to Trash (batch size 10000)')


NOTE:- Fetching a pipeline using pipeline id is much faster than the pipeline name.


0 replies

Be the first to reply!

Reply