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)