생성자
생성자
client): StreamClient
매개변수
| 이름 | Type |
|---|---|
client | Client |
반환값
StreamClient
정의된 위치
메서드
likesCompliance
options?): Promise<EventDrivenStream>
Likes 관련 컴플라이언스 데이터를 스트리밍합니다.
사용자 Likes와 관련된 모든 컴플라이언스 데이터를 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
.on()을 사용해 ‘data’, ‘error’, ‘close’와 같은 이벤트를 수신하세요.
for await…of를 사용한 비동기 반복도 지원합니다.
매개변수
| 이름 | Type |
|---|---|
options | LikesComplianceStreamingOptions |
반환값
Promise<EventDrivenStream>
스트리밍 데이터를 처리하는 이벤트 기반 스트림
정의된 위치
usersCompliance
partition, options?): Promise<EventDrivenStream>
Users 컴플라이언스 데이터를 스트리밍합니다.
Users와 관련된 모든 컴플라이언스 데이터를 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
'data', 'error', 'close'와 같은 이벤트를 수신하려면 .on()을 사용하세요.
for await...of를 사용한 비동기 반복도 지원합니다.
매개변수
| 이름 | type | 설명 |
|---|---|---|
partition | number | 파티션 번호입니다. |
options | UsersComplianceStreamingOptions | - |
반환
Promise<EventDrivenStream>
스트리밍 데이터를 처리하는 이벤트 기반 스트림
정의된 위치
postsFirehoseKo
partition, options?): Promise<EventDrivenStream>
한국어 포스트 스트림
모든 공개된 한국어 포스트를 실시간으로 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
'data', 'error', 'close'와 같은 이벤트를 수신하려면 .on()을 사용하세요.
for await...of 구문을 사용한 비동기 반복도 지원합니다.
매개변수
| Name | Type | Description |
|---|---|---|
partition | number | 파티션 번호. |
options | PostsFirehoseKoStreamingOptions | - |
Returns
Promise<EventDrivenStream>
스트리밍 데이터를 처리하기 위한 이벤트 기반 스트림
정의된 위치
likesSample10
partition, options?): Promise<EventDrivenStream>
좋아요 샘플 스트림실시간으로 공개 좋아요의 10%를 샘플링하여 스트리밍합니다. 사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
.on()을 사용해 'data', 'error', 'close'와 같은 이벤트를 구독하세요.for await...of 구문을 사용하는 비동기 반복도 지원합니다.
매개변수
| Name | Type | Description |
|---|---|---|
partition | number | 파티션 번호. |
options | LikesSample10StreamingOptions | - |
반환값
Promise<EventDrivenStream>
스트리밍 데이터를 처리하기 위한 이벤트 기반 스트림
정의 위치
stream/stream_client.ts:1706likesFirehose
partition, options?): Promise<EventDrivenStream>
모든 좋아요 스트림
실시간으로 모든 공개 좋아요를 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
.on()을 사용해 ‘data’, ‘error’, ‘close’ 등의 이벤트를 처리할 수 있습니다.
for await…of 구문을 사용한 비동기 반복도 지원합니다.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | 파티션 번호. |
options | LikesFirehoseStreamingOptions | - |
반환
Promise<EventDrivenStream>
스트리밍 데이터를 처리하는 이벤트 기반 스트림
정의 위치
stream/stream_client.ts:1983postsFirehoseJa
partition, options?): Promise<EventDrivenStream>
일본어 포스트 스트림
실시간으로 모든 공개 일본어 포스트를 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
'data', 'error', 'close'와 같은 이벤트를 수신하려면 .on()을 사용하세요.
for await...of를 사용한 비동기 반복도 지원합니다.
매개변수
| Name | Type | Description |
|---|---|---|
partition | number | 파티션 번호입니다. |
options | PostsFirehoseJaStreamingOptions | - |
반환 값
Promise<EventDrivenStream>
스트리밍 데이터를 처리하기 위한 이벤트 기반 스트림
정의된 위치
postsFirehoseEn
partition, options?): Promise<EventDrivenStream>
영어 포스트 스트림
실시간으로 모든 공개 영어 포스트를 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
'data', 'error', 'close' 같은 이벤트를 수신하려면 .on() 메서드를 사용하세요.
또한 for await...of를 사용한 비동기 반복도 지원합니다.
매개변수
| Name | Type | Description |
|---|---|---|
partition | number | 파티션 번호입니다. |
options | PostsFirehoseEnStreamingOptions | - |
Returns
Promise<EventDrivenStream>
스트리밍 데이터 처리를 위한 이벤트 기반 스트림
정의 위치
stream/stream_client.ts:2571postsSample
options?): Promise<EventDrivenStream>
샘플링된 포스트를 스트리밍합니다.
실시간으로 공개 포스트의 1%를 샘플링하여 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
'data', 'error', 'close'와 같은 이벤트를 수신하려면 .on()을 사용하세요.
또한 for await...of 구문을 사용하는 비동기 반복도 지원합니다.
매개변수
| 이름 | type |
|---|---|
options | PostsSampleStreamingOptions |
반환
Promise<EventDrivenStream>
스트리밍 데이터를 처리하는 이벤트 기반 스트림
정의된 위치
postsSample10
partition, options?): Promise<EventDrivenStream>
공개 포스트의 10% 샘플 스트림입니다.
실시간으로 공개 포스트의 10% 샘플을 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
'data', 'error', 'close'와 같은 이벤트를 수신하려면 .on()을 사용하세요.
또한 for await...of를 사용한 비동기 반복도 지원합니다.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | 파티션 번호. |
options | PostsSample10StreamingOptions | - |
Returns
Promise<EventDrivenStream>
스트리밍 데이터를 처리하기 위한 이벤트 기반 스트림
정의된 위치
postsCompliance
partition, options?): Promise<EventDrivenStream>
포스트 컴플라이언스 데이터를 스트리밍합니다.
포스트와 관련된 모든 컴플라이언스 데이터를 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
.on()을 사용해 ‘data’, ‘error’, ‘close’와 같은 이벤트를 수신하도록 설정할 수 있습니다.
for await...of를 사용하는 비동기 반복도 지원합니다.
매개변수
| Name | Type | Description |
|---|---|---|
partition | number | 파티션 번호입니다. |
options | PostsComplianceStreamingOptions | - |
반환값
Promise<EventDrivenStream>
스트리밍 데이터를 처리하기 위한 이벤트 기반 스트림입니다.
정의 위치
stream/stream_client.ts:3459labelsCompliance
options?): Promise<EventDrivenStream>
포스트 라벨 스트림포스트에 적용되는 모든 라벨링 이벤트를 스트리밍합니다. 사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
.on()을 사용해 ‘data’, ‘error’, ‘close’와 같은 이벤트를 수신할 수 있습니다.
또한 for await…of를 사용한 비동기 반복도 지원합니다.
매개변수
| 이름 | type |
|---|---|
options | LabelsComplianceStreamingOptions |
Returns
Promise<EventDrivenStream>
스트리밍 데이터를 처리하는 이벤트 기반 스트림
정의된 위치
posts
options?): Promise<EventDrivenStream>
필터링된 포스트를 스트리밍합니다활성 규칙 집합과 일치하는 포스트를 실시간으로 스트리밍합니다. 사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
.on()을 사용해 ‘data’, ‘error’, ‘close’와 같은 이벤트를 리슨하세요.for await...of를 사용하는 비동기 반복도 지원합니다.
매개변수
| 이름 | type |
|---|---|
options | PostsStreamingOptions |
반환값
Promise<EventDrivenStream>
스트리밍 데이터를 처리하기 위한 이벤트 기반 스트림
정의된 위치
postsFirehose
partition, options?): Promise<EventDrivenStream>
모든 포스트 스트리밍
실시간으로 모든 공개 포스트를 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
.on()을 사용하여 'data', 'error', 'close'와 같은 이벤트를 구독할 수 있습니다.
for await...of 구문을 사용한 비동기 반복도 지원합니다.
매개변수
| Name | Type | Description |
|---|---|---|
partition | number | 파티션 번호입니다. |
options | PostsFirehoseStreamingOptions | - |
반환값
Promise<EventDrivenStream>
스트리밍 데이터 처리용 이벤트 기반 스트림
정의된 위치
postsFirehosePt
partition, options?): Promise<EventDrivenStream>
포르투갈어 포스트 스트림
실시간으로 모든 공개 포르투갈어 포스트를 스트리밍합니다.
사용하기 쉬운 이벤트 기반 스트림을 반환합니다.
.on()을 사용해 ‘data’, ‘error’, ‘close’와 같은 이벤트를 수신하세요.
for await...of를 사용한 비동기 반복도 지원합니다.
매개변수
| 이름 | Type | 설명 |
|---|---|---|
partition | number | 파티션 번호입니다. |
options | PostsFirehosePtStreamingOptions | - |
Returns
Promise<EventDrivenStream>
스트리밍 데이터를 처리하기 위한 이벤트 기반 스트림
정의 위치
stream/stream_client.ts:4439getRuleCounts
options?): Promise<Get2TweetsSearchStreamRulesCountsResponse>
스트림 규칙 수 조회필터링된 스트림의 활성 규칙 집합에 포함된 규칙 수를 조회합니다.
매개변수
| 이름 | type |
|---|---|
options | GetRuleCountsStreamingOptions |
반환값
Promise<Get2TweetsSearchStreamRulesCountsResponse>
API 응답을 포함한 Promise
정의된 위치
getRules
options?): Promise<RulesLookupResponse>
스트림 규칙 가져오기
필터링된 스트림에 대해 활성 규칙 집합 또는 일부 규칙을 조회합니다.
매개변수
| 이름 | 타입 |
|---|---|
options | GetRulesStreamingOptions |
Returns
Promise<RulesLookupResponse>
API 응답을 포함하는 Promise
정의된 위치
updateRules
body, options?): Promise<AddOrDeleteRulesResponse>
스트림 규칙 업데이트
필터링된 스트림의 활성 규칙 집합에 규칙을 추가하거나 삭제합니다.
매개변수
| 이름 | type |
|---|---|
body | any |
options | UpdateRulesStreamingOptions |
반환값
Promise<AddOrDeleteRulesResponse>
API 응답을 반환하는 Promise