🔴 실시간 데이터 스트리밍 처리 시스템 구축 (Erlang)

## 프로젝트 개요
이 예제는 Erlang의 강력한 동시성 및 분산 처리 능력을 활용하여 실시간 데이터 스트리밍을 처리하는 간단한 시스템을 구축하는 것을 목표로 합니다. 특히, 센서 네트워크에서 발생하는 데이터를 수집하고, 기본적인 필터링과 집계 연산을 수행하여 중요한 정보를 추출합니다. 이 예제는 Erlang의 `gen_server` 모듈을 사용하여 상태를 관리하고, `lists` 모듈을 활용하여 데이터 처리를 구현하며, Erlang의 특징인 lightweight 프로세스들을 효율적으로 관리하는 방법을 보여줍니다.

## 주요 기능
- **데이터 수집**: 외부 소스 (가상 센서)로부터 실시간 데이터를 수집합니다. 각 센서는 독립적인 Erlang 프로세스로 표현됩니다.
- **필터링**: 특정 조건을 만족하는 데이터만 선택적으로 처리합니다. 예를 들어, 값의 범위에 따라 필터링할 수 있습니다.
- **집계**: 데이터 스트림에서 평균, 최대값, 최소값 등의 통계 정보를 계산합니다.
- **데이터 저장**: 집계된 결과를 임시 저장소 (메모리) 또는 외부 데이터베이스에 저장합니다.
- **오류 처리**: 센서 실패나 네트워크 문제 등 예외 상황에 대한 적절한 오류 처리를 구현합니다.

## 사용 방법
1. Erlang 셸을 실행합니다.
2. 제공된 코드를 Erlang 셸에서 컴파일하고 실행합니다.
3. `process_id()` 함수를 사용하여 각 센서 프로세스의 ID를 확인합니다.
4. 실제 데이터 소스로 대체하여 테스트합니다. (가상 센서로 시작).

## 확장 가능성
- **다양한 필터링 규칙**: 사용자 정의 필터링 규칙을 추가하여 특정 요구 사항에 맞게 시스템을 조정할 수 있습니다.
- **분산 저장소 통합**: Redis, Cassandra 등의 분산 데이터베이스를 사용하여 데이터를 저장하고 관리하는 기능을 추가할 수 있습니다.
- **데이터 시각화**: Grafana, Kibana 등의 데이터 시각화 도구와 연동하여 실시간으로 데이터를 모니터링하고 분석할 수 있습니다.
- **다른 유형의 데이터 스트리밍 처리**: IoT 장비에서 발생하는 다양한 유형의 데이터를 처리하는 기능을 확장할 수 있습니다.

```erlang
%% 센서 프로세스
-module(sensor, [Process]).
-export([start_sensor/2, receive_data/1]).

%% 센서 시작 함수 (process_id, port)
start_sensor(Port) -> 
    {ok, Pid} = gen_server:start_link([{srcdir, "."},{port, Port}, {timeout, 60000}]),  % 60초 타임아웃
    Pid;

%% 데이터 수신 및 처리 함수
receive_data(Data) -> 
    case Data of
        value when is_integer(value) and value > 0 ->  %
            io:format("Received data: ~p~n", [value]),
            {ok, true} ;
        _ -> % 오류 처리: 데이터 형식이 잘못된 경우
            error("Invalid data format received")
    end;

%% 메인 프로세스
-module(main, [start/1]).
-export([start/1]).

start([]) -> 
    {ok, Supervisor} = spawn_supervisor();
    exit("Shutdown", Supervisor).

spawn_supervisor() -> 
    {ok, {Process, Pid}} = gen_server:start_link([{srcdir, "."},{type, supervisor}, {restarts, 2}, {module, sensor}, {id, Pid}]) ;
    Pid;

%% 데이터 스트리밍 시뮬레이션 (테스트용)
main_loop() -> 
    receive("Data") -> main_loop();

```