mirror of https://github.com/dapr/quickstarts.git
41 lines
1013 B
Python
41 lines
1013 B
Python
import time
|
|
import logging
|
|
import requests
|
|
import os
|
|
|
|
logging.basicConfig(level=logging.INFO)
|
|
|
|
base_url = os.getenv('BASE_URL', 'http://localhost') + ':' + os.getenv(
|
|
'DAPR_HTTP_PORT', '3500')
|
|
DAPR_STATE_STORE = 'statestore'
|
|
|
|
for i in range(1, 100):
|
|
orderId = str(i)
|
|
order = {'orderId': orderId}
|
|
state = [{
|
|
'key': orderId,
|
|
'value': order
|
|
}]
|
|
|
|
# Save state into a state store
|
|
result = requests.post(
|
|
url='%s/v1.0/state/%s' % (base_url, DAPR_STATE_STORE),
|
|
json=state
|
|
)
|
|
logging.info('Saving Order: %s', order)
|
|
|
|
# Get state from a state store
|
|
result = requests.get(
|
|
url='%s/v1.0/state/%s/%s' % (base_url, DAPR_STATE_STORE, orderId)
|
|
)
|
|
logging.info('Getting Order: ' + str(result.json()))
|
|
|
|
# Delete state from the state store
|
|
result = requests.delete(
|
|
url='%s/v1.0/state/%s' % (base_url, DAPR_STATE_STORE),
|
|
json=state
|
|
)
|
|
logging.info('Deleted Order: %s', order)
|
|
|
|
time.sleep(1)
|