pyarrow.flight.ServerMiddlewareFactory

class pyarrow.flight.ServerMiddlewareFactory

Bases: pyarrow.lib._Weakrefable

A factory for new middleware instances.

All middleware methods will be called from the same thread as the RPC method implementation. That is, thread-locals set in the middleware are accessible from the method itself.

__init__(*args, **kwargs)

Methods

__init__(*args, **kwargs)
start_call(self, info, headers)	Called at the start of an RPC.

start_call(self, info, headers)

Called at the start of an RPC.

This must be thread-safe.

Parameters

infoCallInfo

Information about the call.

headersdict

A dictionary of headers from the client. Keys are strings and values are lists of strings (for text headers) or bytes (for binary headers).

Returns

instanceServerMiddleware

An instance of ServerMiddleware (the instance to use for the call), or None if this call is not intercepted.

Raises

exceptionpyarrow.ArrowException

If an exception is raised, the call will be rejected with the given error.

previous

pyarrow.flight.RecordBatchStream

next

pyarrow.flight.ServerMiddleware