ELK stack의 브로커로 nsq를 사용하려고합니다. nsq은 elasticsearch에 REST api을 통해 데이터를 보내야한다고 생각했습니다. 그 문서에 따르면, 나는 탄성 검색에 데이터를 추가하는 HTTP PUT 요청을 할 수 있습니다. 그러나 nsq doc에 따르면 nsq는 nsq_to_http 유틸리티를 통해서만 POST 또는 GET 요청을 할
나는 자바 스크립트 var nsq = require('nsqjs');
var reader = new nsq.Reader('output', 'out', {
lookupdHTTPAddresses: '172.32.10.224:4161'
});
reader.connect();
reader.on('message', function (msg)
여기 멍청한 놈이 있긴하지만 아무 예제 나 도움을 찾을 수없는 것 같습니다. NSQ의 작업 인스턴스가 있고 작업, 소비자 등을 등록 할 수 있습니다. 불행히도 원래 시스템을 설정하지 않았습니다. NSQ가 제공하는 명령 줄 도구 (nsq_to_file, nsq_tail 등) 중 일부를 활성화하는 방법을 알아 내려고 노력하고 있습니다. 나는 그들을 발사하는 방
WHAT 4 명의 고객을 사용하여 NSQ 서버에서 메시지를 소비합니다. 이 문제가 발생할 때 backing off 로그가 내 고객으로 느려지는 이유를 디버깅하려고합니다. 예외를 로깅하고 있는데 메시지를 다시 채우려면 False을 반환해야합니다. 로그 된 예외는 보이지 않지만 계속이 메시지가 표시됩니다. 도움!! 문제가 대문자로한다 당신의 아주 마지막 줄 T
nsq 소스 코드의 nsqlookupd 부분을 읽었을 때 저자가 NSQLookupd 구조체를 감싸기 위해 컨텍스트 구조체를 사용하고 Context.I에 다른 funcs를 사용하지 않는 것을 발견했습니다. 왜 우리가이 방식으로 사용하는지, 우리가 할 수있는 이점을 모르겠습니다. 이쪽으로가? 아래 소스 코드. 고맙습니다! func (l *NSQLookupd)
메시징 아키텍처를 사용하는 마이크로 서비스 간의 통신을 해결하고 있습니다. 내가 전통 응용 프로그램을 가지고 있고, User, PostVideo 모듈이 있다고 가정 해 봅시다. 게시물과 동영상을 만들 수는 있지만 그 전에는 사용자 이름을 사용자 ID로 변환해야합니다. 내가 microservice에 모듈을 분리하면 은, 우리가 직접하는 대신 microserv
마이크로 서비스 아키텍처가있는 웹 사이트를 개발 중이며 각 서비스는 데이터베이스를 소유하고 있습니다. 데이터베이스는 마이크로 서비스가 필요로하는 데이터를 저장합니다. Post, Video 서비스는 사용자의 정보가 필요하므로 서비스의 모두는 NEW_USER_EVENT에 가입. NEW_USER_EVENT은 새 사용자가 등록되면 트리거됩니다. 서비스가 NEW_U