lib.sedna.service.client

Module Contents

Classes

LCReporter	Inherited thread, which is an entity that periodically report to
LCClient	send info to LC by http
AggregationClient	Client that interacts with the cloud aggregator.
ModelClient	Remote model service
KBClient	Communicate with Knowledge Base server

Functions

http_request(url[, method, timeout, binary, no_decode])

lib.sedna.service.client.http_request(url, method=None, timeout=None, binary=True, no_decode=False, **kwargs)

class lib.sedna.service.client.LCReporter(lc_server, message, period_interval=30)

Bases: threading.Thread

Inherited thread, which is an entity that periodically report to the lc.

update_for_edge_inference()

update_for_collaboration_inference()

run()

Method representing the thread’s activity.

You may override this method in a subclass. The standard run() method invokes the callable object passed to the object’s constructor as the target argument, if any, with sequential and keyword arguments taken from the args and kwargs arguments, respectively.

class lib.sedna.service.client.LCClient

send info to LC by http

classmethod send(lc_server, worker_name, message: dict)

class lib.sedna.service.client.AggregationClient(url, client_id, **kwargs)

Client that interacts with the cloud aggregator.

max_size

async connect()

send(data, msg_type='message', job_name='')

recv(wait_data_type=None)

class lib.sedna.service.client.ModelClient(service_name, version='', host='127.0.0.1', port='8080', protocol='http')

Remote model service

check_server_status()

inference(x, **kwargs)

Use the remote big model server to inference.

class lib.sedna.service.client.KBClient(kbserver)

Communicate with Knowledge Base server

upload_file(files, name='')

update_db(task_info_file)

update_task_status(tasks: str, new_status=1)