ActivityClient

이 모듈은 X API의 activity 엔드포인트와 상호작용하기 위한 클라이언트를 제공합니다. 실시간 스트리밍 작업은 데이터가 도착하는 대로 이를 산출하는 제너레이터(generator)를 반환합니다. 스트리밍 연결은 지수 백오프 재시도 로직을 통해 자동으로 관리되어, 안정적으로 처리됩니다.

​

ActivityClient

클래스 기반 클래스: object

Activity 작업용 스트리밍 Client

​

생성자

​

__init__

​

매개변수

path.client · Client

​

create_subscription

X activity 이벤트 구독 생성 X activity 이벤트에 대한 구독을 생성합니다 body: 요청 본문 :returns: 응답 데이터 :rtype: CreateSubscriptionResponse

​

매개변수

body.body · CreateSubscriptionRequest

​

delete_subscription

X activity 구독을 삭제합니다 X activity 이벤트 구독을 삭제합니다

​

매개변수

path.subscription_id · Any

삭제할 구독의 ID입니다.

​

반환값

DeleteSubscriptionResponse - 응답 데이터

​

get_subscriptions

X 활동 구독 가져오기 XAA에 대한 활성 구독 목록을 가져옵니다 :returns: 응답 데이터 :rtype: GetSubscriptionsResponse

​

반환값

GetSubscriptionsResponse

​

stream

Activity Stream(스트리밍) X Activity 스트림 이 엔드포인트는 데이터가 생성되는 대로 실시간으로 전송하는 스트리밍 엔드포인트입니다. 각 수신 항목은 스트림에서 나온 하나의 데이터 포인트를 나타냅니다. 연결은 지수적 백오프 재시도 로직을 통해 자동으로 관리됩니다. 스트림이 끊어지면 SDK가 클라이언트의 개입 없이 자동으로 재연결합니다.

​

매개변수

path.backfill_minutes · int or None · 기본값: "None"

요청한 백필(backfill) 분 수입니다.

path.start_time · str or None · 기본값: "None"

YYYY-MM-DDTHH:mm:ssZ. 게시물 레이블이 제공되기 시작하는 가장 이른 UTC 타임스탬프입니다.

path.end_time · str or None · 기본값: "None"

YYYY-MM-DDTHH:mm:ssZ. 게시물 레이블이 제공되는 가장 늦은 UTC 타임스탬프입니다.

path.stream_config · StreamConfig

재시도 동작, 타임아웃, 콜백을 사용자 지정하기 위한 선택적 StreamConfig입니다.

​

update_subscription

X 활동 구독을 업데이트합니다 X 활동 이벤트에 대한 구독을 업데이트합니다

​

매개변수

path.subscription_id · Any

업데이트할 구독의 ID입니다.

body.body · UpdateSubscriptionRequest

요청 본문