-
Notifications
You must be signed in to change notification settings - Fork 581
cruise control client Usage in Python Applications
Like many command-line utilities, cccli
has strengths and weaknesses.
If you need to interact with cruise-control
outside of a command-line (for instance, in a Python
script that does further processing, or in a Python
application that needs to call cruise-control
), you'll want to use cruise-control-client
directly.
Below is a code snippet that starts a rebalance on the cruise-control
instance running at someCruiseControlAddress:9090
.
This is equivalent to the cccli
command
cccli -a someCruiseControlAddress:9090 rebalance
# Note that cccli presumes:
# allow_capacity_estimation=False
# json=True
# dryrun=False
This will generate a POST
request to http://someCruiseControlAddress:9090/kafkacruisecontrol/rebalance?allow_capacity_estimation=False&dryrun=False&json=true
.
from cruisecontrolclient.client.Endpoint import RebalanceEndpoint
from cruisecontrolclient.client.Responder import CruiseControlResponder
# 1) Generate or define the socket address for the desired cruise-control instance
cc_socket_address = 'someCruiseControlAddress:9090'
# 2) Select which endpoint and parameters to use
endpoint = RebalanceEndpoint()
endpoint.add_param(parameter_name="allow_capacity_estimation", value=False)
endpoint.add_param(parameter_name="json", value=True)
# 3) Instantiate a Responder
json_responder = CruiseControlResponder()
# 4) Start a long-running poll to retrieve a Requests.Response object
response = json_responder.retrieve_response_from_Endpoint(cc_socket_address, endpoint)
# 5) Process the response, likely by JSONifying it
json_response = response.json()
Below is a code snippet that starts a broker removal on the cruise-control
instance running at someCruiseControlAddress:9090
.
This is equivalent to the cccli
command
cccli -a someCruiseControlAddress:9090 remove-broker broker,ids,to,remove
# Note that cccli presumes:
# allow_capacity_estimation=False
# json=True
# dryrun=False
This will generate a POST
request to http://someCruiseControlAddress:9090/kafkacruisecontrol/remove_broker?brokerid=broker%2Cids%2Cto%2Cremove&allow_capacity_estimation=False&dryrun=False&json=true
.
from cruisecontrolclient.client.Endpoint import RemoveBrokerEndpoint
from cruisecontrolclient.client.Responder import CruiseControlResponder
# 1) Generate or define the socket address for the desired cruise-control instance
cc_socket_address = 'someCruiseControlAddress:9090'
# 2) Select which endpoint and parameters to use
endpoint = RemoveBrokerEndpoint(['broker', 'ids', 'to', 'remove'])
endpoint.add_param(parameter_name="allow_capacity_estimation", value=False)
endpoint.add_param(parameter_name="json", value=True)
# 3) Instantiate a Responder
json_responder = CruiseControlResponder()
# 4) Start a long-running poll to retrieve a Requests.Response object
response = json_responder.retrieve_response_from_Endpoint(cc_socket_address, endpoint)
# 5) Process the response, likely by JSONifying it
json_response = response.json()
Below is a code snippet that starts a broker addition on the cruise-control
instance running at someCruiseControlAddress:9090
.
This is equivalent to the cccli
command
cccli -a someCruiseControlAddress:9090 add-broker broker,ids,to,add
# Note that cccli presumes:
# allow_capacity_estimation=False
# json=True
# dryrun=False
This will generate a POST
request to http://someCruiseControlAddress:9090/kafkacruisecontrol/add_broker?brokerid=broker%2Cids%2Cto%2Cadd&allow_capacity_estimation=False&dryrun=False&json=true
.
from cruisecontrolclient.client.Endpoint import AddBrokerEndpoint
from cruisecontrolclient.client.Responder import CruiseControlResponder
# 1) Generate or define the socket address for the desired cruise-control instance
cc_socket_address = 'someCruiseControlAddress:9090'
# 2) Select which endpoint and parameters to use
endpoint = AddBrokerEndpoint(['broker', 'ids', 'to', 'add'])
endpoint.add_param(parameter_name="allow_capacity_estimation", value=False)
endpoint.add_param(parameter_name="json", value=True)
# 3) Instantiate a Responder
json_responder = CruiseControlResponder()
# 4) Start a long-running poll to retrieve a Requests.Response object
response = json_responder.retrieve_response_from_Endpoint(cc_socket_address, endpoint)
# 5) Process the response, likely by JSONifying it
json_response = response.json()
Contents
- Cruise Control Wiki
- Overview
- Troubleshooting
- User Guide
- Python Client
- Developer Guide