Toggle Light / Dark / Auto color theme

Toggle table of contents sidebar

jina.clients.base.helper module

class jina.clients.base.helper.AioHttpClientlet(url, logger)

Bases: abc.ABC

aiohttp session manager

HTTP Client to be used with the streamer

Parameters

• url (str) – url to send http/websocket request to

• logger (JinaLogger) – jina logger

abstract async send_message()

Send message to Gateway

abstract async recv_message()

Receive message from Gateway

async start()

Create ClientSession and enter context

Returns

self

async close(*args, **kwargs)

Close ClientSession

Parameters

• args – positional args

• kwargs – keyword args

class jina.clients.base.helper.HTTPClientlet(url, logger)

Bases: jina.clients.base.helper.AioHttpClientlet

HTTP Client to be used with the streamer

HTTP Client to be used with the streamer

Parameters

• url (str) – url to send http/websocket request to

• logger (JinaLogger) – jina logger

async send_message(request)

Sends a POST request to the server

Parameters

request (Request) – request as dict

Returns

send post message

async recv_message()

Receive message for HTTP (sleep)

Returns

await sleep

class jina.clients.base.helper.WebsocketClientlet(*args, **kwargs)

Bases: jina.clients.base.helper.AioHttpClientlet

Websocket Client to be used with the streamer

HTTP Client to be used with the streamer

Parameters

• url – url to send http/websocket request to

• logger – jina logger

async send_message(request)

Send request in bytes to the server.

Parameters

request (Request) – request object

Returns

send request as bytes awaitable

async send_eoi()

To confirm end of iteration, we send bytes(True) to the server.

Returns

send bytes(True) awaitable

async recv_message()

Receive messages in bytes from server and convert to Response

..note::

aiohttp allows only one task which can receive concurrently. we need to make sure we don’t create multiple tasks with recv_message

Yield

response objects received from server

Return type

Response