camera-agent

camera-agent Project

프로젝트 소개

Camera Agent Project는 컨테이너 기반으로 MobileX Station에 부착된 웹캠 카메라들을 IP 카메라처럼 활용할 수 있게 하는 프로젝트로 Falcon을 보완하기 위해 진행되었습니다. 이 프로젝트의 주요 목표는 다음과 같습니다:

1. 웹캠을 IP 카메라로 변환: 기존 MobileX Station의 웹캠을 IP 카메라와 같은 기능성을 가진 장치로 전환합니다. 이를 통해 네트워크를 통한 원격 접근과 제어가 가능해집니다.

2. 중앙화된 카메라 관리: WebUI를 통해 현재 사용 가능한 모든 카메라의 목록을 확인하고 관리할 수 있습니다. 이는 시스템 관리자에게 직관적이고 효율적인 카메라 관리 환경을 제공합니다.

3. 서비스 모니터링: 카메라를 사용하는 다양한 서비스들의 상태를 실시간으로 확인하고 추적할 수 있는 기능을 제공합니다. 이를 통해 시스템의 안정성과 성능을 지속적으로 모니터링하고 개선할 수 있습니다.

이 프로젝트는 기존 하드웨어 자원을 최대한 활용하면서도 IP 카메라의 유연성과 기능성을 제공함으로써, 코드 재사용성을 높이고 디지털 트윈 프로젝트와 연계하여 개발 진행 예정입니다.

web-UI 는 light 버전만 지원됩니다.

그 외 프로젝트 요구사항 관련

기존에 사이트가 없어서 해당 서버의 경우 요구사항을 README.md 에 같이 정리했었는데 , 이후 생성되는 DT 서비스 관련 repo 와 프로젝트들의 요구사항은 아래 사이트에서 별도로 통합 유지 관리 예정 입니다.

https://smartx-team.github.io/digital-twin-hub/

프로젝트 주요 목표 및 작업 진행률

• 전체 진행률: [X]% 완료
  • 도커 이미지 기반으로 Agent 와 Agent 관리를 위한 visibility 서버 간에 통신 구현 (K8S 위에서 최종 배포 테스트 필요)
  • Agent의 영상간에 시간 동기화를 위해 PTP 서버 구현 및 동기화 테스트 (구현 되었으나 활성화 필요)
  • WebUI 기반으로 Agent 상태 조회 및 관리 (구현 완료)
  • Omnivese 에서 생성된 가상 카메라 정보 추가 및 동기화 (구현 필요)
  • 프로메테우스 서버와 연동하여 Agent의 인프라 사용량 관리
  • Argo CD , NIFI 등 그래픽 기반으로 전체 서비스 관리및 Live X+AI 서비스 구현 (24년도 10월안 Falcon 연계로 테스트 준비)

프로젝트 관리

Swagger 로 기본 API 사용법이 제공되긴하나 Omniverse 전체 API 를 관리하는 gitblog 생성하여 해당 Repo에 API 및 문서 이력 관리 진행 예정

전체 구조도

ver 240930

Agent 와 visibility Server 통신

Web-UI 동작 예시

주요 컴포넌트 및 기능

1. Agent

주요 스택: FAST API(gRPC로 대체될 수 있음), Gstreamer

목적: Gstreamer 기반으로 웹캠과 같은 일반 카메라 장비를 IP 카메라 처럼 사용할수 있도록 지원하고, 카메라 상태를 주기적으로 Visibility Server 에 주기적으로 전송

또한 스트리밍 on/off 등 동적으로 조절할 수 있는 API를 지원하여, 네트워크 상태등에 따라 유동적으로 생성되는 데이터 크기를 조절할 수 있음

Rtsp 프로토콜로 스트리밍 되기에 여러 서비스에서 동시에 카메라의 데이터에 접근하기 수월해지고, 전체 시스템를 관리하기도 쉬어짐

–

주요 기능:

• 기능 1: Gstreamer 기반으로 일반 카메라를 rtsp 프로토콜로 스트리밍할 수 있도록 지원
• 기능 2: PTP 프로토콜로 Agent들간 시간 동기화 (구현은 했으나 안정화 확인되면 이후에 다시 활성화할 예정)
• 기능 3: Prometheus 로 현재 Agent의 시스템 사용량 관리

구현된 세부 요구사항:

• 요구사항 1: Agent 생성시 Visibility Server 에 등록 API 호출
• 요구사항 2: 주기적으로 Visibility Server에 카메라 상태 업데이트
• 요구사항 3: FAST API 기반 스트리밍 송출 on/off 구현
• 요구사항 4: PTP 프로토콜 동기화 (가능은 한데 안전성 때문에 현재 실 사용은 안하고 있음)
• 요구사항 5: UWB 서버 연동하여 현재 웹캠카메라가 설치된 Host PC 의 위치좌표 web_ui 에 같이 노출하기
• 요구사항 6: 쿠버네티스 API와 연동하여 현재 Agent가 돌아가고 있는 PC의 Name web_ui 에 같이 노출하기

자세한 정보: Agent/README.md

2. Visibility Server

주요 스택: Flask, tinyDB

목적: Agent 들의 현재 상태를 관리하고, 사용자가 사용하는 WebUI 를 위해 기본적인 CRUD 기능 지원

주요 기능:

• 기능 1: Agent 가 신규 등록시 DB 에 관련 정보 유지 및 관리
• 기능 2: 사용자가 Agent의 카메라 조작 가능한 엔드포인트 API 제공
• 기능 3: 사용자가 사용하는 web-ui 에서 사용가능한 엔드포인트 API 제공
• 기능 4: 프로메테우스 서버 연동하여 agent 들의 컴퓨팅 사용량 조회

구현된 요구사항:

• 기능 1 관련:
  • 1.1: Agent 신규 등록 시 필요한 정보 정의 및 DB 스키마 Open API 등과 연계
  • 1.2: Agent 정보 등록, 조회, 수정 API 구현
  • 1.3: DB에 동일 IP 대역이 있으면 신규 ID 발급하지 말고 기존 agent 정보에 업데이트 지원
• 기능 2 관련:
  • 2.1: Agent 스트림(on/off) 조작 API 구현
• 기능 3 관련:
  • 3.1: web-ui용 Agent 목록 조회 API 구현
  • 3.2: web-ui용 Agent 상세 정보 조회 API 구현
• 기능 4 관련:
  • 4.1: 프로메테우스 연동을 위한 메트릭 수집 및 제공 기능 구현

비기능적 요구사항:

• [] NFR 1: Agent들은 기본 컨테이너 단위로 동작하며, Agent 삭제 기능은 Argo CD 와 같은 툴을 이용해 구현예정임

자세한 정보: Backend/README.md

3. PTP Server

목적: Agent들의 시간 동기화를 위한 컨테이너 기반 PTP 서버

주요 기능:

• 기능 1: [설명]

  구현된 요구사항:

• 요구사항 1: [설명]

자세한 정보:

4. WebUI

목적: Agent들의 관리를 위한 WebUI

주요 기능:

• 기능 1: Agent가 신규 등록 시 DB에 관련 정보 유지 및 관리
• 기능 2: 사용자가 Agent의 카메라를 제어할 수 있는 엔드포인트 API 제공
• 기능 3: 사용자가 사용하는 WebUI에서 사용 가능한 엔드포인트 API 제공
• 기능 4: Prometheus 서버 연동하여 Agent들의 컴퓨팅 자원 사용량 조회
• 기능 5: CORS 설정을 통한 Cross-Origin 요청 허용
• 기능 6: rtsp 프로토콜 말고도 다른 프로토콜로 비디오 데이터 처리 구현 필요

구현된 요구사항:

• 기능 1 관련:
  • 1.1: Agent 신규 등록 시 필요한 정보 정의 및 DB 스키마, OpenAPI 연계
    • rtsp_port와 agent_port를 분리하여 저장하도록 DB 스키마 수정
    • Swagger 문서(agent_register.yml)에 agent_port 필드 추가
  • 1.2: Agent 정보 등록, 조회, 수정 API 구현
    • AgentRegister 클래스에서 agent_port를 처리하도록 수정
    • AgentModel과 Database 클래스에서 agent_port를 저장 및 관리하도록 수정
  • 1.3: DB에 동일 IP가 있으면 신규 ID 발급하지 않고 기존 Agent 정보 반환
    • TinyDB 쿼리 및 데이터 구조 수정으로 중복 등록 문제 해결
    • IP 주소를 기준으로 기존 Agent 검색 및 반환 로직 구현
• 기능 2 관련:
  • 2.1: Agent 스트림(On/Off) 제어 API 구현
    • SetFrameTransmission 엔드포인트에서 Agent의 IP와 포트를 통해 스트림 제어 명령 전송
    • Agent의 /start_stream 및 /stop_stream 엔드포인트와 연동
  • 2.2: Agent의 API 포트를 사용하여 통신하도록 수정
    • Agent 등록 시 agent_port 정보를 포함하여 서버에 전달
    • 서버에서 Agent의 agent_port를 사용하여 통신
• 기능 3 관련:
  • 3.1: WebUI용 Agent 목록 조회 API 구현
    • Agent 목록을 반환하는 엔드포인트 구현
  • 3.2: WebUI용 Agent 상세 정보 조회 API 구현
    • 특정 Agent의 상세 정보를 반환하는 엔드포인트 구현
  • 3.3: CORS 설정을 통해 WebUI에서 API 호출 가능하도록 설정
    • Flask와 FastAPI 애플리케이션에서 CORS 설정 추가
• 기능 4 관련:
  • 4.1: Prometheus 연동을 위한 메트릭 수집 및 제공 기능 구현
    • 진행 중: Prometheus와의 연동을 위한 메트릭 수집 기능 개발 필요
• 기능 5 관련:
  • 5.1: CORS 설정을 통한 Cross-Origin 요청 허용
    • Flask 앱에서 flask_cors를 사용하여 CORS 설정 추가
    • FastAPI 앱에서 CORSMiddleware를 사용하여 CORS 설정 추가
  • 5.2: Preflight 요청에 대한 처리 로직 추가
    • OPTIONS 메서드를 허용하고 적절한 CORS 헤더를 반환하도록 수정

비기능적 요구사항:

• [] NFR 1: Web-UI 는 빠른 개발을 위해 제이쿼리 위주의 간단한 UI 버전 과 이후 세부적인 기능을 위한 전문 프레임워크를 사용한 버전 추가 개발 요청

자세한 정보:

설치 및 실행 방법

모든 서버 기능들은 컨테이너 베이스로 유지됨, 도커 파일은 프로젝트마다 있음 MobileX 에서는 K8S 에 자동 배포 유지되도록 세팅 해둘것임