Định nghĩa schema
Hãy bắt đầu bằng cách định nghĩa schema kỳ vọng cho việc kiểm định dữ liệu. Đây là bước quan trọng để đảm bảo chất lượng dữ liệu xuyên suốt pipeline ETL.
Bạn sẽ dùng thư viện pointblank để định nghĩa cấu trúc schema.
Bộ dữ liệu đã được nạp sẵn dưới biến ts.
Bài tập này là một phần của khóa học
Thiết kế Pipeline Dự báo cho Môi trường Production
Hướng dẫn bài tập
- Bắt đầu bằng cách import
pointblank. - Định nghĩa schema bằng phương thức phù hợp.
- Đặt cột
respondentkiểuobjectvà cộtvaluekiểufloat64.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
# Import the required library
import ____ as ____
# Define the schema and set columns
table_schema = pb.____(
columns=[
("period", "datetime64[ns]"),
("respondent", "____"),
("respondent-name", "object"),
("type", "object"),
("type-name", "object"),
("value", "____"),
("value-units", "object")])
print(table_schema)