Read this document in another language: English, 正體中文

Visit our blog post on the API wrapper project to learn more about our initiatives. If you have any questions, please reach out to Onfleet by submitting an issue here or contact [email protected]

• Onfleet Python Wrapper
  • Table of Contents
  • Synopsis
  • Installation
  • Usage
    • Throttling
    • Responses
    • Supported CRUD Operations
      • GET Requests
        • Examples of get()
        • Examples of get(param)
        • Examples of getByLocation:
      • POST Requests
        • Examples of create()
      • PUT Requests
        • Examples of update()
        • Examples of updateSchedule()
        • Examples of insertTask()
      • DELETE Requests
        • Examples of deleteOne()

The Onfleet Python library provides convenient access to the Onfleet API.

pip install pyonfleet

Before using the API wrapper, you will need to obtain an API key from your organization admin. Creation and integration of API keys are performed through the Onfleet dashboard.

To authenticate, you will also need to create a file named .auth.json under your working directory, this is where you will store your API credentials.

The format of .auth.json is shown below:

{
    "API_KEY": "<your_api_key>", 
}

You can also opt in to not store your API key here and use it on the fly instead.

Once the Onfleet object is created, you will get access to all the API endpoints as documented in the Onfleet API documentation. Here are some usage case:

from onfleet import Onfleet

api = Onfleet() # if .auth.json was provided
api = Onfleet(api_key="<your_api_key>") # if no .auth.json was provided

Rate limiting is enforced by the API with a threshold of 20 requests per second across all your organization's API keys, learn more about it here.

The pyonfleet API wrapper returns the body of a Response object.

The base URL for the Onfleet API is https://onfleet.com/api/v2, here are the supported CRUD operations for each endpoint:

To get all the documents within an endpoint:

get()

api.workers.get()
api.workers.get(queryParams="")

Option to use query parameters for some certain endpoints, refer back to API documents for endpoints that support query parameters:

api.workers.get(queryParams="phones=<phone_number>")

or

api.workers.get(queryParams={"phones":"<phone_number>"})

To get one of the document within an endpoint, specify the param that you wish to search by:

get(param=<some_param>)

api.workers.get(id="<24_digit_id>")
api.workers.get(id="<24_digit_id>", queryParams={"analytics": "true"})
api.tasks.get(shortId="<shortId>")
api.recipients.get(phone="<phone_number>")
api.recipients.get(name="<recipient_name>")

api.containers.get(workers="<worker_id>")
api.containers.get(teams="<team_id>")
api.containers.get(organizations="<org_id>")

To get a driver by location, use the getByLocation function:

getByLocation(queryParams=<some_param>)

params = {"longitude":"-122.4","latitude":"37.7601983","radius":"6000"}
api.workers.getByLocation(queryParams=params)

To create a document within an endpoint:

create(body="<body_object>")

driver = {
  "name": "A Swartz Test",
  "phone": "+16173428853",
  "teams": ["<a_team_id>", "<a_team_id> (optional)..."],
  "vehicle": {
    "type": "CAR",
    "description": "Tesla Model S",
    "licensePlate": "FKNS9A",
    "color": "purple",
  }
}

api.workers.create(body=driver)

Extended POST requests include clone, forceComplete, batchCreate, autoAssign on the tasks endpoint, and setSchedule on the workers endpoint:

api.tasks.clone(id="<24_digit_id>")
api.tasks.forceComplete(id="<24_digit_id>", body="<completion_details>")
api.tasks.batchCreate(body="<task_object_get>")
api.tasks.autoAssign(body="<auto_assign_object>")

api.workers.setSchedule(id="<24_digit_id>", body="<schedule_object>")

For more details, check our documentation on clone, forceComplete, batchCreate, autoAssign, and setSchedule

To update a document within an endpoint:

update(id="<24_digit_id>", body="<body_object>")

updateBody = {
    "name": "New Driver Name",
}
api.workers.update(id="<24_digit_id>", body=updateBody)

api.workers.updateSchedule(id="<24_digit_id>", body=newSchedule)

For more details, check our documentation on updateSchedule

api.workers.insertTask(id="kAQ*G5hnqlOq4jVvwtGNuacl", body="<body_object>")

To delete a document within an endpoint:

deleteOne(id="<24_digit_id>")

api.workers.deleteOne(id="<24_digit_id>")