Get a specific Data Source by Data Flow Node ID
{ getSourceByNode }
Returns the data source connection details using it's node ID in a data flow.
Method
/API3/dataSources/getSourceByNode
- Enterprise Admin
Input Parameters
Name
findDataSourceObject
Object Type
Description
Use this object to find a specific data source
Output Response
Successful Result Code
200
Response Type
Description of Response Type
The master flow data source object contains information about the connection of a specific source ETL node or master flow sql script node and the validation message result
Notes
Use this function with other methods to update the details of a data source.
Code Snippets
Use the Authentication API methods to generate an access 'key' or 'token' for use in code as shown below.
TypeScript
Curl
Java
C#
Python
PHP
curl -X POST \
-H "paToken: [[apiKey]]" \
-H "Accept: application/json,application/json;charset=utf-8,text/plain,text/plain;charset=utf-8" \
-H "Content-Type: application/json" \
"http://Your.Server.URL/API3/dataSources/getSourceByNode" \
-d '{
"itemId" : "itemId",
"dataFlowNodeId" : "dataFlowNodeId"
}'
import com.pyramidanalytics.*;
import com.pyramidanalytics.auth.*;
import com.pyramidanalytics.model.*;
import com.pyramidanalytics.api.DataSourcesServiceApi;
import java.util.*;
import java.time.*;
public class DataSourcesServiceApiExample {
public static void main(String[] args) {
ApiClient defaultClient = Configuration.getDefaultApiClient();
defaultClient.setBasePath("http://Your.Server.URL/");
// Configure API key authorization: paToken
ApiKeyAuth paToken = (ApiKeyAuth) defaultClient.getAuthentication("paToken");
paToken.setApiKey("YOUR API KEY");
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//paToken.setApiKeyPrefix("Token");
// Create an instance of the API class
DataSourcesServiceApi apiInstance = new DataSourcesServiceApi();
// Initialize the findDataSourceObject parameter object for the call
MasterFlowFindDataSourceObject findDataSourceObject = ; // Create the input object for the operation, type: MasterFlowFindDataSourceObject
try {
MasterFlowSourceObject result = apiInstance.getSourceByNode(findDataSourceObject);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling DataSourcesServiceApi#getSourceByNode");
e.printStackTrace();
}
}
}
import * as PyramidAnalyticsWebApi from "com.pyramidanalytics";
// Create an instance of the API class
const api = new PyramidAnalyticsWebApi.DataSourcesServiceApi("http://Your.Server.URL")
// Configure API key authorization: paToken
api.setApiToken("YOUR API KEY");
const findDataSourceObject = ; // {MasterFlowFindDataSourceObject}
api.getSourceByNode(findDataSourceObject).then(function(data) {
console.log('API called successfully. Returned data: ' + data);
}, function(error) {
console.error(error);
});
using System;
using System.Diagnostics;
using PyramidAnalytics.Sdk.Api;
using PyramidAnalytics.Sdk.Client;
using PyramidAnalytics.Sdk.Model;
public class getSourceByNodeExample
{
public static void Main()
{
Configuration conf = new Configuration();
conf.BasePath = "http://Your.Server.URL/";
// Configure API key authorization: paToken
conf.ApiKey.Add("paToken", "YOUR_API_KEY");
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// conf.ApiKeyPrefix.Add("paToken", "Bearer");
GlobalConfiguration.Instance = conf;
// Create an instance of the API class
var apiInstance = new DataSourcesServiceApi();
// Initialize the findDataSourceObject parameter object for the call
var findDataSourceObject = new MasterFlowFindDataSourceObject(); // MasterFlowFindDataSourceObject |
try {
// Returns the data source connection details using it's node ID in a data flow.
MasterFlowSourceObject result = apiInstance.getSourceByNode(findDataSourceObject);
Debug.WriteLine(result);
} catch (Exception e) {
Debug.Print("Exception when calling DataSourcesServiceApi.getSourceByNode: " + e.Message );
}
}
}
import com.pyramidanalytics
from com.pyramidanalytics import ApiException
from com.pyramidanalytics import DataSourcesServiceApi
from pprint import pprint
# Configure API key authorization: paToken
api_config = com.pyramidanalytics.Configuration(host = 'http://Your.Server.URL/', api_key={ paToken:'YOUR_ACCESS_TOKEN' })
with com.pyramidanalytics.ApiClient(api_config) as api_client:
# Create an instance of the API class
api_instance = DataSourcesServiceApi(api_client)
# Initialize the findDataSourceObject parameter object for the call
findDataSourceObject = # MasterFlowFindDataSourceObject |
try:
# Returns the data source connection details using it's node ID in a data flow.
api_response = api_instance.get_source_by_node(findDataSourceObject)
pprint(api_response)
except ApiException as e:
print("Exception when calling DataSourcesServiceApi->getSourceByNode: %s\n" % e)
<?php
require_once(__DIR__ . '/vendor/autoload.php');
OpenAPITools\Client\Configuration::getDefaultConfiguration()->setHost('http://Your.Server.URL');
// Configure API key authorization: paToken
OpenAPITools\Client\Configuration::getDefaultConfiguration()->setApiKey('paToken', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// OpenAPITools\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('paToken', 'Bearer');
// Create an instance of the API class
$api_instance = new OpenAPITools\Client\Api\DataSourcesServiceApi();
$findDataSourceObject = ; // MasterFlowFindDataSourceObject |
try {
$result = $api_instance->getSourceByNode($findDataSourceObject);
print_r($result);
} catch (Exception $e) {
echo 'Exception when calling DataSourcesServiceApi->getSourceByNode: ', $e->getMessage(), PHP_EOL;
}
?>