빨대가있는 데이터 흐름 프로그래밍

클래식 컴퓨팅 모델 인 DataFlow 프로그래밍은 웹 스케일 실시간 서비스의 급증 덕분에 부흥을 경험하고 있습니다. 고유 한 단순성, 확장 성 및 자원 효율성은 수많은 엔지니어링 문제에 이상적입니다. Node.js 프레임 워크 인 Straw, Node.js 프레임 워크는 원래 실시간 재무 데이터 처리를 위해 설계되었으며 겸손한 하드웨어에서 초당 수천 개의 메시지를 처리 ​​할 수있는 데이터 흐름 구현을 용이하게합니다. 짚 구조 코드는 상호 연결된 노드로 코딩합니다. 각 노드는 입력을 수신하고, 처리하고, 결과를 출력합니다. 이 모듈 식 설계는 복잡한 문제를 단순화하여 확장 성과 탄력성을 향상시킵니다. 이 기사는 트윗 데이터에 대한 마이닝 트위터의 Firehose의 응용 프로그램을 자세히 설명하여 Straw의 기능을 보여줍니다. 이 프로세스에는 원시 데이터를 수집하고 분석을 수행하며 실시간 시각화를 위해 Websockets를 통해 Express Server 및 클라이언트에 결과를 배포하기위한 노드 설정이 포함됩니다. <p> 짚과 건초 더미 소개 </p> <a> Straw는 각각 입력 및 0 이상의 출력을 가진 노드의 토폴로지를 정의합니다. 노드는 사용자 정의 기능을 사용하여 들어오는 메시지를 처리하여 연결된 노드에 대한 출력 메시지를 생성합니다. 예제 응용 프로그램 인 Haystack에는 Firehose의 원시 데이터 소비를위한 노드, 분석을위한 데이터 라우팅 및 분석 노드 자체가 포함됩니다. 그런 다음 데이터를 WebSockets를 통해 Express 서버 및 클라이언트로 전환합니다. 따라 가려면 건초 더미를 로컬로 설치하십시오. Redis와 Bower는 전제 조건입니다. 바워 설치 : <ation ation>. 건초 더미 클로닝 및 설정 : <p> </p> 소방서 데이터 스트림 실행 <p> <twitter twitter> 트위터 소방서에 액세스하려면 트위터 앱 (읽기 권한 만 읽기)을 만들어 API 자격 증명이 필요합니다. API 키 탭에서 , <strong>, </strong> 및 <lo>를 얻으십시오. 자격 증명을 사용하여 Haystack의 샘플 구성 파일을 업데이트하십시오 </lo></twitter></p> <ack> 두 개의 개별 터미널을 사용하여 건초 더미를 실행합니다. <ization ization> <p> <code>npm install -g bower

짚 토폴로지 이해 (run.js) 는 밀짚 토폴로지를 정의합니다. 노드와 연결은 객체에 지정됩니다. 예를 들면 : 노드는

디렉토리에 있습니다. (입력 없음) 메시지를 소개합니다. 선택적 메시지 라우팅에 대한 여러 출력을 보여줍니다 예제 노드 (cofume-firehose.js 및 route-tweets.js)

consumer_key : consumer_secret access_token_key :

git clone https://github.com/simonswain/haystack
cd haystack
npm install
bower install

캐치 라인 노드 (언어 집계의 경우)

압도적 인 고객을 피하기 위해 정기적으로 총을 방출합니다. 를 사용하여 방출을 제어하고, 언어 수를 증가시키고, 변화가 발생할 때 총계를 방출합니다. . Express Server (Server.js) 및 클라이언트 측 시각화 (Haystack.js) 는 Express and Socket.io (또는 Sockjs)를 사용하여 웹 인터페이스를 제공하고 A

를 사용하여 Straw에서 데이터를 스트리밍합니다. 클라이언트 측 () 은이 데이터를 수신하고 시각화합니다 결론

catch-langs Haystack은 실시간 데이터 스트림의 데이터 흐름 처리를 예시합니다. 짚의 고유 한 평행과 모듈성은 복잡한 작업을 단순화합니다. 노드와 시각화를 추가하여 건초 더미를 확장합니다 DataFlow 프로그래밍에 대한 자주 묻는 질문 (FAQ) setInterval (이 섹션은 자체 포함 된 FAQ 섹션이므로 입력에서 크게 변경되지 않은 상태로 유지됩니다. t이 다시 쓰기의 목적으로 수정이 필요합니다.

위 내용은 빨대가있는 데이터 흐름 프로그래밍의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!