Skip to main content

rb_flat_buffers

rb_flat_buffersschemas/*.fbs로부터 생성된 Python FlatBuffer 코드 패키지입니다.

핵심 요약

  • 소스 스키마: /schemas/**/*.fbs
  • 생성 결과 1: backend/packages/rb_flat_buffers/src/rb_flat_buffers/** (FlatBuffer Python generated code)
  • 생성 결과 2: backend/packages/rb_schemas/src/rb_schemas/fbs_models/** (Pydantic 모델)

즉, make backend.flatc를 실행하면:

  1. FlatBuffer Python 코드가 rb_flat_buffers에 생성되고
  2. 동일 스키마 기반 Pydantic 모델이 rb_schemas에 생성됩니다.

생성 방법

프로젝트 루트에서:

make backend.flatc

backend.mkbackend.flatc 타깃은 내부적으로 아래를 순서대로 실행합니다.

  1. scripts/backend/generate_flatbuffers.py
  • flatc --python --gen-object-api --gen-all 기반 생성
  • 출력: backend/packages/rb_flat_buffers/src/rb_flat_buffers
  1. backend/packages/rb_flat_buffers/scripts/patch_imports.py
  • generated import 경로/누락 import 보정
  1. scripts/backend/fbs_to_pydantic.py
  • .fbs를 Pydantic 모델로 변환
  • 출력: backend/packages/rb_schemas/src/rb_schemas/fbs_models

언제 실행해야 하나

아래 케이스에서는 make backend.flatc를 다시 실행해야 합니다.

  • schemas/*.fbs 수정
  • 신규 .fbs 파일 추가/삭제
  • FlatBuffer 타입/필드 변경(table/struct/enum/union)

rb_flat_buffers 사용 예시

예: 요청 객체 전송 + 값이 채워진 FlatBuffer 응답(returnValue) 수신

# server/queryable 쪽
from rb_flat_buffers.IPC.Request_Move_SmoothJogStop import Request_Move_SmoothJogStopT
from rb_flat_buffers.IPC.Response_Functions import Response_FunctionsT
from rb_zenoh.router import ZenohRouter

router = ZenohRouter()

@router.queryable(
    "C500920/call_smoothjog_stop",
    flatbuffer_req_t=Request_Move_SmoothJogStopT,
    flatbuffer_res_buf_size=64,
)
def on_call_pause(req, params=None):
    print(req.stoptime)  # 요청으로 전달된 값 사용 가능
    res = Response_FunctionsT()
    res.returnValue = 123  # 빈 payload가 아니라 실제 값 포함
    return res
# client/query 쪽
from rb_flat_buffers.IPC.Request_Move_SmoothJogStop import Request_Move_SmoothJogStopT
from rb_flat_buffers.IPC.Response_Functions import Response_FunctionsT
from rb_zenoh.client import ZenohClient

client = ZenohClient()
req = Request_Move_SmoothJogStopT()
req.stoptime = 0.7

res = client.query_one(
    "C500920/call_smoothjog_stop",
    flatbuffer_req_obj=req,
    flatbuffer_res_T_class=Response_FunctionsT,
    flatbuffer_buf_size=64,
)

obj = res.get("obj_payload")
print(obj.returnValue)  # 123

rb_schemas(Pydantic) 사용 예시

query_one 응답의 obj_payload를 Pydantic으로 validate한 뒤, model_dump에서 원하는 key case를 선택할 수 있습니다.

from rb_flat_buffers.IPC.Response_Functions import Response_FunctionsT
from rb_schemas.fbs_models.nexus.v1.deploy_models import Response_Deploy_UploadPD
from rb_utils.parser import t_to_dict
from rb_zenoh.client import ZenohClient

client = ZenohClient()

res = client.query_one(
    "deploy/call_upload",
    flatbuffer_res_T_class=Response_FunctionsT,
    timeout=0.3,
)

obj_payload = res.get("obj_payload")

# 1) FlatBuffer T 객체 -> dict 변환
raw_dict = t_to_dict(obj_payload) if obj_payload is not None else {}

# 2) Pydantic validate
pd_obj = Response_Deploy_UploadPD.model_validate(raw_dict)

# 3) key case 선택
snake_case = pd_obj.model_dump(by_alias=False)  # ex) return_value
camel_case = pd_obj.model_dump(by_alias=True)   # ex) returnValue

주의사항

  • 패키지명은 rb_flat_buffers입니다. (rb_flat_buffer 아님)
  • generated 파일은 수동 수정하지 않는 것을 권장합니다.
  • flatc가 PATH에 없으면 make backend.flatc가 실패합니다.

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

rainbow_rb_flat_buffers-0.1.0.tar.gz (441.9 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

rainbow_rb_flat_buffers-0.1.0-py3-none-any.whl (1.4 MB view details)

Uploaded Python 3

File details

Details for the file rainbow_rb_flat_buffers-0.1.0.tar.gz.

File metadata

  • Download URL: rainbow_rb_flat_buffers-0.1.0.tar.gz
  • Upload date:
  • Size: 441.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/7.0.0 CPython/3.12.5

File hashes

Hashes for rainbow_rb_flat_buffers-0.1.0.tar.gz
Algorithm Hash digest
SHA256 b64753c673f6270f1e4ffc48cdd2fa13c46ccdbdbd8f1d5d7f62567f43caff85
MD5 8fab0760cf7f14f43114b093686bb54b
BLAKE2b-256 acfc50ccfeadd0e758baba19d6aeb5cd36834ffb53ca07725a37ad9fd6205cf7

See more details on using hashes here.

File details

Details for the file rainbow_rb_flat_buffers-0.1.0-py3-none-any.whl.

File metadata

File hashes

Hashes for rainbow_rb_flat_buffers-0.1.0-py3-none-any.whl
Algorithm Hash digest
SHA256 ed072e3e921307272fcd0e437f1b73982934b60fd71f471e9c6add65244ec0f7
MD5 275e8aeb0d69b55d9be51d556b60a5e0
BLAKE2b-256 d83fa07a2873f814ff2af081516efafc00904702ccc7f4b0351001a1855c3e0e

See more details on using hashes here.

Release history Release notifications | RSS feed

0.1.1

2 files

This release

0.1.0 This release

2 files

0.0.79

2 files

0.0.78

2 files

0.0.77

2 files

0.0.76

2 files

0.0.75

2 files

0.0.74

2 files

0.0.73

2 files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page