🔧 플랫폼별 활용법

from apache_atlas.client.base_client import AtlasClient
from apache_atlas.model.instance import AtlasEntity

# 클라이언트 초기화
client = AtlasClient('http://atlas:21000', ('admin', 'password'))

# Hive 테이블 엔티티 생성
table = AtlasEntity(
    typeName='hive_table',
    attributes={
        'qualifiedName': 'sales.customers@production',
        'name': 'customers',
        'description': '고객 정보 테이블',
        'owner': 'data-team@company.com'
    }
)

# 엔티티 생성
response = client.entity.create_entity(table)
print(f"Created entity: {response.guid}")

from datahub.emitter.mce_builder import make_dataset_urn
from datahub.emitter.rest_emitter import DatahubRestEmitter
from datahub.metadata.schema_classes import DatasetPropertiesClass

# Emitter 초기화
emitter = DatahubRestEmitter('http://datahub-gms:8080')

# Dataset URN 생성
dataset_urn = make_dataset_urn(
    platform='postgres',
    name='prod_db.public.customers',
    env='PROD'
)

# 메타데이터 생성
properties = DatasetPropertiesClass(
    description='고객 정보를 저장하는 메인 테이블',
    customProperties={
        'owner': 'data-team@company.com',
        'quality_score': '0.95'
    }
)

# 메타데이터 발행
emitter.emit_mcp(
    MetadataChangeProposal(
        entityUrn=dataset_urn,
        aspectName='datasetProperties',
        aspect=properties
    )
)

import requests

# API 설정
BASE_URL = 'https://company.collibra.com'
API_KEY = 'your-api-key'
headers = {
    'Authorization': f'Bearer {API_KEY}',
    'Content-Type': 'application/json'
}

# 자산 생성
asset_data = {
    'name': 'customers',
    'displayName': 'Customers Table',
    'typeId': '00000000-0000-0000-0000-000000031007',  # Table type
    'domainId': 'customer-domain-id',
    'statusId': 'active-status-id'
}

response = requests.post(
    f'{BASE_URL}/rest/2.0/assets',
    headers=headers,
    json=asset_data
)

asset = response.json()
print(f"Created asset: {asset['id']}")