swagger_client.ProvenanceeventsApi

All URIs are relative to http://localhost/nifi-api

Method	HTTP request	Description
get_input_content	GET /provenance-events/{id}/content/input	Gets the input content for a provenance event
get_output_content	GET /provenance-events/{id}/content/output	Gets the output content for a provenance event
get_provenance_event	GET /provenance-events/{id}	Gets a provenance event
submit_replay	POST /provenance-events/replays	Replays content from a provenance event

get_input_content

StreamingOutput get_input_content(id, cluster_node_id=cluster_node_id)

Gets the input content for a provenance event

Example

from __future__ import print_function
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ProvenanceeventsApi()
id = 'id_example' # str | The provenance event id.
cluster_node_id = 'cluster_node_id_example' # str | The id of the node where the content exists if clustered. (optional)

try: 
    # Gets the input content for a provenance event
    api_response = api_instance.get_input_content(id, cluster_node_id=cluster_node_id)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ProvenanceeventsApi->get_input_content: %s\n" % e)

Parameters

Name	Type	Description	Notes
id	str	The provenance event id.
cluster_node_id	str	The id of the node where the content exists if clustered.	[optional]

Return type

StreamingOutput

Authorization

No authorization required

HTTP request headers

• Content-Type: /
• Accept: /

[Back to top] [Back to API list] [Back to Model list] [Back to README]

get_output_content

StreamingOutput get_output_content(id, cluster_node_id=cluster_node_id)

Gets the output content for a provenance event

Example

from __future__ import print_function
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ProvenanceeventsApi()
id = 'id_example' # str | The provenance event id.
cluster_node_id = 'cluster_node_id_example' # str | The id of the node where the content exists if clustered. (optional)

try: 
    # Gets the output content for a provenance event
    api_response = api_instance.get_output_content(id, cluster_node_id=cluster_node_id)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ProvenanceeventsApi->get_output_content: %s\n" % e)

Parameters

Name	Type	Description	Notes
id	str	The provenance event id.
cluster_node_id	str	The id of the node where the content exists if clustered.	[optional]

Return type

StreamingOutput

Authorization

No authorization required

HTTP request headers

• Content-Type: /
• Accept: /

[Back to top] [Back to API list] [Back to Model list] [Back to README]

get_provenance_event

ProvenanceEventEntity get_provenance_event(id, cluster_node_id=cluster_node_id)

Gets a provenance event

Example

from __future__ import print_function
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ProvenanceeventsApi()
id = 'id_example' # str | The provenance event id.
cluster_node_id = 'cluster_node_id_example' # str | The id of the node where this event exists if clustered. (optional)

try: 
    # Gets a provenance event
    api_response = api_instance.get_provenance_event(id, cluster_node_id=cluster_node_id)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ProvenanceeventsApi->get_provenance_event: %s\n" % e)

Parameters

Name	Type	Description	Notes
id	str	The provenance event id.
cluster_node_id	str	The id of the node where this event exists if clustered.	[optional]

Return type

ProvenanceEventEntity

Authorization

No authorization required

HTTP request headers

• Content-Type: /
• Accept: application/json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

submit_replay

ProvenanceEventEntity submit_replay(body)

Replays content from a provenance event

Example

from __future__ import print_function
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.ProvenanceeventsApi()
body = swagger_client.SubmitReplayRequestEntity() # SubmitReplayRequestEntity | The replay request.

try: 
    # Replays content from a provenance event
    api_response = api_instance.submit_replay(body)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling ProvenanceeventsApi->submit_replay: %s\n" % e)

Parameters

Name	Type	Description	Notes
body	SubmitReplayRequestEntity	The replay request.

Return type

ProvenanceEventEntity

Authorization

No authorization required

HTTP request headers

• Content-Type: application/json
• Accept: application/json

[Back to top] [Back to API list] [Back to Model list] [Back to README]