Skip to main content

Xplenty API Python SDK

Project description

## Xplenty Python 3 Wrapper

Updated the Python 2 [xplenty.py](https://github.com/xplenty/xplenty.py) using
[`2to3`](https://docs.python.org/2/library/2to3.html)

The Xplenty PY is a python artifact that provides a simple wrapper for the [Xplenty REST API](https://github.com/xplenty/xplenty-api-doc). To use it, create an XplentyClient object and call its methods to access the Xplenty API. This page describes the available XplentyClient methods.

### Installation

Via pip:
```bash
pip install xplenty
```

### Create an Xplenty Client Object
Pass your account ID and API key to the XplentyClient constructor.
```python
from xplenty import XplentyClient
account_id ="MyAccountID"
api_key = "V4eyfgNqYcSasXGhzNxS"
client = XplentyClient(account_id,api_key)
```
### Create a Cluster

This method creates a new cluster. A cluster is a group of machines ("nodes") allocated to your account. The number of nodes in the cluster is determined by the "nodes" value that you supply to the call. While the cluster is active, only your account's users can run jobs on the cluster.
You will need to provide an active cluster when starting a new job. Save the cluster ID value returned in the response "id" field. You will use the value to refer to this cluster in subsequent API calls.
```python
cluster_type = "production"
nodes = 2
name ="New Cluster #199999"
description ="New Cluster's Description"
terminate_on_idle = False
time_to_idle = 3600
cluster = client.create_cluster(cluster_type, nodes, name, description, terminate_on_idle, time_to_idle)
print cluster.id
```
### List All Clusters

This method returns the list of clusters that were created by users in your account.
You can use this information to monitor and display your clusters and their statuses.
```python
clusters = client.clusters
print "Number of clusters:",len(clusters)
for cluster in clusters:
print cluster.id, cluster.name, cluster.created_at
```
### Get Cluster Information

This method returns the details of the cluster with the given ID.
```python
id = 85
cluster = client.get_cluster(id)
print cluster.name
```
### Terminate a Cluster

This method deactivates the given cluster, releasing its resources and terminating its runtime period. Use this method when all of the cluster's jobs are completed and it's no longer needed. The method returns the given cluster's details, including a status of "pending_terminate".
```python
id = 85
cluster = client.terminate_cluster(id)
print cluster.status
```
### Run a Job

This method creates a new job and triggers it to run. The job performs the series of data processing tasks that are defined in the job's package. Unless the job encounters an error or is terminated by the user, it will run until it completes its tasks on all of the input data. Save the job ID value returned in the response "id" field. You will use the value to refer to this job in subsequent API calls.
```python
cluster_id = 83
package_id = 782
variables = {}
variables['OUTPUTPATH']="test/job_vars.csv"
variables['Date']="09-10-2012"

job = client.add_job(cluster_id, package_id, variables)

print job.id
```
### List All Jobs

This method returns information for all the jobs that have been created under your account.
```python
jobs = client.jobs

for job in jobs:
print job.id , job.progress , job.status
```
### Get Job Information

This method retrieves information for a job, according to the given job ID.
```python
job_id = 235
job = client.get_job(job_id)
print job.status
```
### Terminate a Job

This method terminates an active job. Usually it's unnecessary to request to terminate a job, because normally the job will end when its tasks are completed. You may want to actively terminate a job if you need its cluster resources for a more urgent job, or if the job is taking too long to complete.
```python
job_id = 235
job = client.stop_job(job_id)
print job.status
```

### List All Packages

This method returns the list of packages that were created by users in your account.
You can use this information to display your packages and their properties.
```python
packages = client.packages
print "Number of packages:",len(packages)
for package in packages:
print package.id, package.name, package.created_at
```
### Get Package Information

This method returns the details of the package with the given ID.
```python
id = 85
package = client.get_package(id)
print package.name
```

## Contributing

1. Fork it
2. Create your feature branch (`git checkout -b my-new-feature`)
3. Commit your changes (`git commit -am 'Add some feature'`)
4. Push to the branch (`git push origin my-new-feature`)
5. Create new Pull Request

## License
Released under the [MIT license](http://www.opensource.org/licenses/mit-license.php).

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

xplenty3-0.1.1.tar.gz (7.9 kB view details)

Uploaded Source

File details

Details for the file xplenty3-0.1.1.tar.gz.

File metadata

  • Download URL: xplenty3-0.1.1.tar.gz
  • Upload date:
  • Size: 7.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No

File hashes

Hashes for xplenty3-0.1.1.tar.gz
Algorithm Hash digest
SHA256 34150a5466ac73958118c25881ef8c397bc4f7b6b84919c591b290e166086af2
MD5 21d1bb2b575ad6ee559bcb1228e35c86
BLAKE2b-256 37157b5ccdec09fd01b1ea89697757582ada275b2240647933b6fbe7841d4cad

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page