import { DataPipelineClient, ActivatePipelineCommand } from "@aws-sdk/client-data-pipeline"; // ES Modules import
// const { DataPipelineClient, ActivatePipelineCommand } = require("@aws-sdk/client-data-pipeline"); // CommonJS import
const client = new DataPipelineClient(config);
const command = new ActivatePipelineCommand(input);
const response = await client.send(command);
import * as AWS from "@aws-sdk/client-data-pipeline";
const client = new AWS.DataPipeline({ region: "REGION" });
// async/await.
try {
const data = await client.activatePipeline(params);
// process data.
} catch (error) {
// error handling.
}
// Promises.
client
.activatePipeline(params)
.then((data) => {
// process data.
})
.catch((error) => {
// error handling.
});
// callbacks.
client.activatePipeline(params, (err, data) => {
// proccess err and data.
});
import { DataPipelineClient, ValidatePipelineDefinitionCommand } from "@aws-sdk/client-data-pipeline"; // ES Modules import
// const { DataPipelineClient, ValidatePipelineDefinitionCommand } = require("@aws-sdk/client-data-pipeline"); // CommonJS import
const client = new DataPipelineClient(config);
const command = new ValidatePipelineDefinitionCommand(input);
const response = await client.send(command);
import { DataPipelineClient, DeactivatePipelineCommand } from "@aws-sdk/client-data-pipeline"; // ES Modules import
// const { DataPipelineClient, DeactivatePipelineCommand } = require("@aws-sdk/client-data-pipeline"); // CommonJS import
const client = new DataPipelineClient(config);
const command = new DeactivatePipelineCommand(input);
const response = await client.send(command);
import { DataPipelineClient, CreatePipelineCommand } from "@aws-sdk/client-data-pipeline"; // ES Modules import
// const { DataPipelineClient, CreatePipelineCommand } = require("@aws-sdk/client-data-pipeline"); // CommonJS import
const client = new DataPipelineClient(config);
const command = new CreatePipelineCommand(input);
const response = await client.send(command);