Avro を使用して、さまざまなアプリケーション間でオブジェクトをシリアル化するためのバイナリ形式を標準化したいと考えています。アプリケーション自体は Avro RPC を使用して通信しません。おそらく、ZeroMQ のようなものが使用されるでしょう。
Python クライアントが Scala サーバーと通信する単純なプロトタイプを作成しようとしています。Scala 側では問題ありませんが、Python 側で何をすべきかよくわかりません。公式ガイドや多くのブログ記事に従おうとしました。
ガイドと私が見つけた投稿の両方で、例はファイルからの書き込み/読み取り方法、または Avro を介した RPC の方法のみを示しています。オブジェクトの Avro バイト表現を書きたい
- 記憶の中で、そして
- スキーマを含めずに
送信側と受信側の両方にスキーマのコピーを展開しても問題ありませんが、メッセージはアトミックになるため、スキーマ自体は移動しないでください。リクエストごとにスキーマを送信するオーバーヘッドは望ましくありません。
上記はpython avroライブラリで可能ですか?