project-lib for Python (더 이상 사용되지 않음)

프로젝트 정보 페치

다음 함수를 사용하여 프로젝트 관련 정보를 프로그래밍 방식으로 페치할 수 있습니다.

• get_name()

  이 함수는 프로젝트의 이름을 리턴합니다.

• get_description()

  이 함수는 프로젝트의 설명을 리턴합니다.

• get_metadata()

  이 함수는 프로젝트 메타데이터를 리턴합니다.

• get_files()

  이 함수는 프로젝트의 파일 목록을 리턴합니다. 리턴된 목록에서 각 요소는 파일의 ID와 이름을 포함합니다. 리턴된 파일 목록은 임의의 기준으로 정렬되지 않으며 함수를 다시 호출할 때 변경될 수 있습니다.

• get_assets()

  이 함수는 모든 프로젝트 자산 목록을 리턴합니다. 선택적 매개변수 asset_type을(를) 유형별로 자산을 필터링할 수 있는 get_assets 함수에 전달할 수 있습니다. 이 매개변수에 허용되는 값은 data_asset, connection 및 asset입니다. asset 값은 프로젝트의 모든 자산을 리턴합니다. 예를 들어, 데이터 자산만 가져오려면 get_assets("data_asset") 함수를 사용하십시오.

• get_connections()

  이 함수는 프로젝트에 있는 연결 목록을 리턴합니다. 리턴된 목록에서 각 요소는 연결의 ID와 이름을 포함합니다.

파일 페치

다음 함수를 사용하여 프로젝트와 연관된 파일을 페치할 수 있습니다.

• get_file(file_name) 여기서 file_name은(는) 페치할 파일의 이름입니다.

  이 함수는 파일을 실행 중인 커널의 메모리로 페치합니다. 이 함수는 pandas DataFrame과 같은 커널 특정 데이터 구조에 바인드하는 데 사용할 수 있는 바이트 버퍼를 리턴합니다. 이 파일 페치 메소드는 매우 큰 파일에는 권장되지 않습니다.

  다음 예제는 파일을 페치하고 데이터를 pandas DataFrame으로 읽는 방법을 보여줍니다.

  # Import the lib
  from project_lib import Project
  project = Project.access()
  
  # Fetch the file
  my_file = project.get_file("myFile.csv")
  
  # Read the CSV data file into a pandas DataFrame
  my_file.seek(0)
  import pandas as pd
  pd.read_csv(my_file, nrows=10)
  

데이터 저장

다음 기능을 사용하여 프로젝트와 연관된 파일에 데이터를 저장할 수 있습니다. 이 함수는 여러 작업을 수행합니다. 먼저 데이터를 파일에 넣은 후 이 데이터를 프로젝트에 데이터 자산으로 추가하여 프로젝트의 데이터 자산 목록에서 파일로 저장한 데이터를 볼 수 있습니다.

save_data(file_name, data, set_project_asset=True, overwrite=False)

함수는 다음 매개변수를 사용합니다.

• file_name: 작성된 파일의 이름.

• data: 업로드할 데이터. 이는 file-like-object 유형의 오브젝트(예: 바이트 버퍼 또는 문자열 버퍼)일 수 있습니다.

  참고: 로드할 데이터의 크기는 2GB를 초과할 수 없습니다.

• set_project_asset[optional]: 데이터가 파일에 성공적으로 업로드된 후 파일을 데이터 자산으로 프로젝트에 추가합니다. 부울 값을 사용하며 기본적으로 true 값이 설정됩니다.

• overwrite[optional]: 파일이 이미 있는 경우 파일을 겹쳐씁니다. 이는 기본적으로 false로 설정됩니다.

다음은 데이터를 파일에 저장하는 방법을 보여주는 예제입니다.

# Import the lib
from project_lib import Project
project = Project.access()

# let's assume you have the pandas DataFrame  pandas_df which contains the data
# you want to save as a csv file
project.save_data("file_name.csv", pandas_df.to_csv(index=False))

# the function returns a dict which contains the asset_id and file_name
# upon successful saving of the data

연결에서 데이터 읽기

다음 함수를 사용하여 지정된 연결의 메타데이터(인증 정보)를 가져올 수 있습니다.

get_connection: 함수는 연결의 ID 또는 연결 이름을 입력으로 사용합니다. 프로젝트에 나열된 모든 자산의 id, name 및 type을(를) 리턴하는 get_assets() 함수를 사용하여 이러한 값을 얻을 수 있습니다.

get_connection 함수는 연결 데이터 소스에서 데이터를 페치하는 데 사용할 수 있는 연결 신임 정보를 리턴합니다.

다음은 get_connection 함수를 사용하여 연결의 신임 정보를 페치하는 방법을 보여주는 예제입니다.

# Import the lib
from project_lib import Project
      project = Project.access()

conn_creds = project.get_connection(name="<ConnectionName>")

예를 들어 연결이 dashDB에 대한 연결인 경우 다음 코드를 실행하여 데이터를 페치할 수 있습니다.

from pyspark.sql import SparkSession
spark = SparkSession.builder.getOrCreate()

host_url = "jdbc:db2://{}:{}/{}".format(conn_creds["host"], "50000", conn_creds["database"])
data_df = spark.read.jdbc(host_url, table="<TableName>", properties={"user": conn_creds["username"], "password": conn_creds["password"]})
data_df.show()

연결된 데이터 페치

다음 함수를 사용하여 연결된 데이터의 인증 정보를 페치할 수 있습니다. 이 함수는 해당 연결의 특정 데이터를 가리키는 datapath 속성(예: dashDB 인스턴스의 테이블 또는 Cloudant 인스턴스의 데이터베이스)을 포함하는 사전을 리턴합니다.

get_connected_data: 이 함수는 연결된 데이터의 ID 또는 연결된 데이터의 이름을 입력으로 사용합니다. 프로젝트에 나열된 모든 자산의 id, name 및 type을(를) 리턴하는 get_assets() 함수를 사용하여 이러한 값을 얻을 수 있습니다.

다음은 get_connected_data 함수를 사용하여 dashDB 인스턴스에서 연결된 데이터의 신임 정보를 페치하는 방법을 보여주는 예제입니다.

# Import the lib
from project_lib import Project
project = Project.access()

creds = project.get_connected_data(name="<ConnectedDataName>")
# creds is a dictionary that has the connection credentials in addition to
# a datapath that references a specific table in the database, for example:
# creds: {'database': 'DB_NAME',
# 'datapath': '/DASHDB/SAMPLE_TABLE',
# 'host': 'hostname',
# 'password': 'XXXX',
# 'sg_service_url': 'https://sgmanager.ng.bluemix.net',
# 'username': 'XXXX'}