import

입력되는 모든 레코드를 지정된 테이블에 기록합니다. 클러스터 관리자 권한이 필요합니다.

명령어 속성

문법

옵션

create=BOOL

t로 설정하면 대상 테이블이 존재하지 않을 때 자동으로 테이블을 생성합니다. 이 옵션은 시스템 속성 araqne.logdb.import_create_option이 활성화된 환경에서만 사용할 수 있습니다. (기본값: f)

_sk=STR

파티션 서브키 필드 이름. 레코드를 저장할 때 파티션을 결정하는 서브키 값을 읽어올 필드를 지정합니다. (기본값: _sk)

대상

TABLE

레코드를 기록할 대상 테이블 이름

입력 필드

출력 필드

입력 레코드의 필드를 그대로 전달합니다.

오류 코드

파싱 오류

런타임 오류

해당 사항 없음

설명

import 명령어는 입력되는 모든 레코드를 지정된 테이블에 기록하고, 입력 레코드를 다음 명령어로 전달합니다. 각 레코드의 _time 필드 값을 저장 시각으로 사용하며, _time 필드가 없거나 날짜 타입이 아닌 경우 현재 시각을 사용합니다.

_table, _id, _sk, _era, _sto_class 필드는 스토리지가 직접 관리하는 시스템 예약 필드이므로, 입력 레코드에 이 필드들이 포함되어 있어도 저장 데이터에서 제외됩니다. 예를 들어 다른 테이블에서 조회한 레코드를 import로 저장해도, 원본 레코드에 담겨 있던 _table 값이 사용자 데이터로 함께 저장되지 않고 저장 위치를 기준으로 한 값이 조회됩니다.

레코드가 한 건씩 또는 일반 배치 단위로 처리되는 경우에는 저장용 데이터에서만 이 필드들을 제거하며, 다음 명령어로 전달되는 레코드에는 원본 필드가 그대로 남아 있습니다. 반면 벡터 배치 단위로 처리되는 경우에는 배치 자체에서 이 필드들을 제거한 뒤 다음 명령어로 전달하므로, 예를 들어 table A | import B | fields _table처럼 import 뒤에서 이 필드들을 참조하면 값이 비어 있을 수 있습니다.

스토리지가 읽기 전용 상태이거나 쓰기 중 오류가 발생하면 쿼리가 취소됩니다.

분산 환경에서는 분석 노드에서 실행됩니다.

사용 예

이 사용 예에서 조회하는 WEB_APACHE_SAMPLE 테이블을 준비하려면 쿼리 실습용 데이터를 참고하세요.

1. 테이블에 레코드 기록

   table WEB_APACHE_SAMPLE | import WEB_APACHE_BACKUP
   

   WEB_APACHE_SAMPLE 테이블의 전체 데이터를 WEB_APACHE_BACKUP 테이블에 기록합니다.

2. 집계 결과를 테이블에 저장

   table WEB_APACHE_SAMPLE
   | stats count by method
   | import WEB_METHOD_STATS
   

   WEB_APACHE_SAMPLE 테이블의 데이터를 HTTP 메서드별로 집계하여 WEB_METHOD_STATS 테이블에 저장합니다.

3. 파티션 서브키 필드 지정

   table WEB_APACHE_SAMPLE
   | import _sk=src_ip WEB_APACHE_BY_IP
   

   src_ip 필드의 값을 파티션 서브키로 사용하여 WEB_APACHE_BY_IP 테이블에 기록합니다.

변경 이력