How to import a pipeline using python SDK?

  • 13 December 2023
  • 0 replies
  • 11 views

Badge
from streamsets.sdk import ControlHub
from streamsets.sdk import DataCollector
from streamsets.sdk import sch_models
import json
DataCollector.VERIFY_SSL_CERTIFICATES = False

###Add the sdc details of your environment
sdc = DataCollector('http://localhost:18650/', username='admin', password='admin')


pipeline_json = sdc.export_pipeline(pipeline=sdc.pipelines.get(title='stop test'),
include_library_definitions=True,
include_plain_text_credentials=True)

with open('./from_sdc_for_sdc.json', 'w') as f:
json.dump(pipeline_json, f)

 


0 replies

Be the first to reply!

Reply