sparkworksrest 1.0.13

要求。

Python 2.7和3.4+

安装和使用

pip install sparkworksrest

（您可能需要使用root权限运行pip： sudo pip install sparkworksrest）

然后导入包：

Python客户端文档

有关客户的文档可以在上找到 Github

设置对SparkWorks Rest API的访问

importsparkworks_client# Configure OAuth2 access token for authorization: oauth2configuration=sparkworks_client.Configuration("username","password","client_id","client_secret")configuration.connect()# create an instance of the API classapi_client=sparkworks_client.ApiClient(configuration)#initialize the clients neededunit_api_instance=sparkworks_client.UnitApi(api_client)group_api_instance=sparkworks_client.GroupApi(api_client)phenomenon_api_instance=sparkworks_client.PhenomenonApi(api_client)gateway_api_instance=sparkworks_client.GatewayApi(api_client)resource_api_instance=sparkworks_client.ResourceApi(api_client)command_api_instance=sparkworks_client.CommandApi(api_client)registry_api_instance=sparkworks_client.RegistryApi(api_client)data_api_instance=sparkworks_client.DataApi(api_client)participatorySensing_api_instance=sparkworks_client.ParticipatorySensingApi(api_client)

示例

importtimeimportsparkworks_client# Configure OAuth2 access token for authorization: oauth2configuration=sparkworks_client.Configuration("username","password","client_id","client_secret")configuration.connect()print("access_token: "+configuration.access_token)# create an instance of the API classapi_client=sparkworks_client.ApiClient(configuration)resource_api_instance=sparkworks_client.ResourceApi(api_client)unit_api_instance=sparkworks_client.UnitApi(api_client)phenomenon_api_instance=sparkworks_client.PhenomenonApi(api_client)data_api_instance=sparkworks_client.DataApi(api_client)# list all Resourcesresources=resource_api_instance.get_resources()print("====resource====")# retrieve resource by uuidresource=resource_api_instance.get_resource_by_uuid(resources[0].uuid)print(resource)print("====phenomenon====")phenomenon=phenomenon_api_instance.get_phenomenon_by_uuid(resource.phenomenon_uuid)print(phenomenon)print("====unit====")unit=unit_api_instance.get_unit_by_uuid(resource.unit_uuid)print(unit)time_from=(int(round(time.time()))-5*60*60)*1000time_to=int(round(time.time()))*1000print("====data 5min====")# retrieve data - granularity 5mindata=data_api_instance.query_time_range({"queries":[{"from":time_from,"to":time_to,"granularity":"5min","resourceUuid":resource.uuid}]})fordindata.results.values():fordatumind.data:print("5min",datum)print("====data hour====")# retrieve data - granularity hourdata=data_api_instance.query_time_range({"queries":[{"from":time_from,"to":time_to,"granularity":"hour","resourceUuid":resource.uuid}]})fordindata.results.values():fordatumind.data:print("hour",datum)

importsparkworks_client# Configure OAuth2 access token for authorization: oauth2configuration=sparkworks_client.Configuration("username","password","client_id","client_secret")configuration.connect()print("access_token: "+configuration.access_token)# create an instance of the API classapi_client=sparkworks_client.ApiClient(configuration)resource_api_instance=sparkworks_client.ResourceApi(api_client)group_api_instance=sparkworks_client.GroupApi(api_client)print("====groups====")# list all groupsgroups=group_api_instance.get_all_groups()forgroupingroups:print(group)print("====group[0].resources====")# retrieve resources by group uuidresources=group_api_instance.get_group_resources(groups[0].uuid)forresourceinresources:print(resource)