Arrow Flight

警告

Flight 目前不稳定。API 可能会更改，但我们预计不会有剧烈变化。

常见类型

Action(action_type, buf)	可在 Flight 服务上执行的操作。
ActionType(type, description)	可在 Flight 服务上执行的操作类型。
DescriptorType(*values)	FlightDescriptor 的类型。
FlightDescriptor()	Flight 服务中可用数据流的描述。
FlightEndpoint(ticket, locations[, ...])	一个 Flight 流，以及访问它的票据和位置。
FlightInfo(Schema schema, ...[, ...])	Flight 流的描述。
Location(uri)	Flight 服务的位置。
MetadataRecordBatchReader	Flight 流读取器的基类。
MetadataRecordBatchWriter	一个 RecordBatchWriter，也允许写入应用程序元数据。
Ticket(ticket)	请求 Flight 流的票据。
Result(buf)	执行 Action 的结果。

Flight 客户端

connect(location, **kwargs)	连接到 Flight 服务器。
FlightCallOptions([timeout, write_options, ...])	Flight 调用 RPC 层选项。
FlightClient(location[, tls_root_certs, ...])	Flight 服务的客户端。
FlightStreamReader	一个也可取消的读取器。
FlightStreamWriter	一个也允许关闭流写入端的写入器。
ClientMiddlewareFactory	新中间件实例的工厂。
ClientMiddleware	用于调用的客户端中间件，每个 RPC 实例化一次。

Flight 服务器

FlightDataStream	Flight 数据流的抽象基类。
FlightMetadataWriter	在 DoPut 期间发送 Flight 元数据消息的发送方。
FlightServerBase([location, auth_handler, ...])	Flight 服务定义。
GeneratorStream(schema, generator[, options])	由 Python 生成器支持的 Flight 数据流。
RecordBatchStream(data_source[, options])	由 RecordBatches 支持的 Flight 数据流。
ServerCallContext	每次调用的状态/上下文。
ServerMiddlewareFactory	新中间件实例的工厂。
ServerMiddleware	调用的服务器端中间件，按 RPC 实例化。

认证

ClientAuthHandler	客户端认证插件。
ServerAuthHandler	服务器认证中间件。

错误

FlightError([message, extra_info])	Flight 特定错误的基类。
FlightCancelledError	操作已取消。
FlightInternalError	Flight 服务器内部发生错误。
FlightServerError	发生服务器错误。
FlightTimedOutError	Flight RPC 调用超时。
FlightUnauthenticatedError	客户端未经身份验证。
FlightUnauthorizedError	客户端未被授权执行给定操作。
FlightUnavailableError	服务器不可达或不可用。
FlightWriteSizeExceededError(message, limit, ...)	写入操作超出客户端配置的限制。

中间件

FlightMethod(*values)	Flight 中实现的方法。
CallInfo(method)	关于 Flight 中间件特定 RPC 的信息。