스크립트 개발 / 커넥터 객체 DFF.CONN / Alibaba Cloud Log Service SLS

Alibaba Cloud Log Service SLS 커넥터 작업 객체는 Project와 Logstore를 나열하고 로그를 조회하는 데 사용됩니다.

DFF.CONN(...) 매개변수는 다음과 같습니다:

매개변수	타입	필수 / 기본값	설명
connector_id	str	필수	커넥터 ID

AccessKey 자격 증명은 커넥터 구성에서 가져오므로 스크립트 코드에 전달할 필요가 없고 전달해서도 안 됩니다.

.list_projects()

현재 자격 증명으로 액세스할 수 있는 Project 이름을 반환하며, 형식은 list[str]입니다.

sls = DFF.CONN('aliyun_sls_connector_id')
projects = sls.list_projects()

이 메서드는 SDK의 기본 페이징 매개변수를 사용하며, 한 번에 최대 100개의 Project를 반환하고 페이징 매개변수 전달은 지원하지 않습니다.

.list_logstores(...)

지정된 Project의 Logstore를 나열합니다. 매개변수는 다음과 같습니다:

매개변수	타입	필수 / 기본값	설명
project	str	필수	Project 이름

반환 값 형식은 list[str]입니다.

logstores = sls.list_logstores('example-project')

이 메서드는 SDK의 기본 페이징 매개변수를 사용하며, 한 번에 최대 100개의 Logstore를 반환하고 페이징 매개변수 전달은 지원하지 않습니다.

.query(...)

지정된 Project 및 Logstore의 로그를 조회합니다. 매개변수는 aliyun-log-python-sdk의 로그 조회 인터페이스에 직접 전달됩니다:

매개변수	타입	필수 / 기본값	설명
project	str	필수	Project 이름
logstore	str	필수	Logstore 이름
from_time	int/str	필수	조회 시작 시간. Unix 초 타임스탬프 또는 SLS에서 지원하는 읽을 수 있는 시간 문자열을 전달할 수 있습니다
to_time	int/str	필수	조회 종료 시간. Unix 초 타임스탬프 또는 SLS에서 지원하는 읽을 수 있는 시간 문자열을 전달할 수 있습니다
topic	str	None	로그 토픽 제한
query	str	None	SLS 조회 구문
reverse	bool	False	최신 로그를 우선 반환할지 여부
offset	int	0	반환 결과의 시작 오프셋
size	int	100	최대 반환 건수; -1은 전체 결과를 요청함
power_sql	bool	False	향상된 SQL 모드 사용 여부
scan	bool	False	Scan 조회 모드 사용 여부
forward	bool	True	Scan 조회의 페이지 넘김 방향. True는 다음 페이지, False는 이전 페이지
accurate_query	bool	True	정밀 조회 모드 사용 여부
from_time_nano_part	int	0	조회 시작 시간의 나노초 부분
to_time_nano_part	int	0	조회 종료 시간의 나노초 부분

sls = DFF.CONN('aliyun_sls_connector_id')

query_args = {
    'project'  : 'example-project',
    'logstore' : 'application',
    'from_time': _DFF_TRIGGER_TIME - 3600,
    'to_time'  : _DFF_TRIGGER_TIME,
    'query'    : 'error',
    'size'     : 100,
}
logs = sls.query(**query_args)

반환 값 형식은 list[dict]이며, 각 로그에는 다음 필드가 포함됩니다:

필드	타입	설명
contents	dict	로그 내용
timestamp	int	로그 시간, Unix 초 타임스탬프

SDK 조회 실패 시 해당 예외가 직접 위로 전달됩니다.

조회 범위 및 반환 건수 제한

대규모 로그 조회는 높은 비용이 발생할 수 있습니다. 예약 작업은 _DFF_TRIGGER_TIME을 사용하여 안정적인 조회 창을 구성하고, 실제 필요에 따라 시간 범위와 size를 제한해야 합니다.