Giới thiệu
Microsoft Fabric cung cấp khả năng Trí tuệ Thời gian Thực, cho phép bạn tạo ra các giải pháp phân tích cho các luồng dữ liệu theo thời gian thực. Trong bài viết này, chúng ta sẽ sử dụng các khả năng này để nhập, phân tích và trực quan hóa dữ liệu thị trường chứng khoán theo thời gian thực.
Tạo Workspace
Trước khi làm việc với dữ liệu trong Fabric, bạn cần tạo một workspace với khả năng Fabric được kích hoạt.
- Truy cập trang chủ Microsoft Fabric tại đây và đăng nhập bằng thông tin xác thực Fabric của bạn.
- Trong thanh menu bên trái, chọn Workspaces.
- Tạo một workspace mới với tên mà bạn chọn, chọn chế độ cấp phép bao gồm khả năng Fabric.
- Khi workspace mới của bạn mở ra, nó sẽ trống rỗng.
Tạo Eventstream
Bây giờ bạn đã sẵn sàng để tìm và nhập dữ liệu theo thời gian thực từ một nguồn phát sóng. Để làm điều này, bạn sẽ bắt đầu tại Fabric Real-Time Hub.
- Trong thanh menu bên trái, chọn Real-Time hub. Hub thời gian thực cung cấp một cách dễ dàng để tìm và quản lý các nguồn dữ liệu phát sóng.
- Trong hub thời gian thực, trong phần Connect to, chọn Data sources.
- Tìm nguồn dữ liệu mẫu thị trường chứng khoán và chọn Connect. Trong wizard kết nối, đặt tên cho nguồn là stock và chỉnh sửa tên eventstream mặc định thành stock-data. Stream mặc định liên quan đến dữ liệu này sẽ tự động được đặt tên là stock-data-stream.
- Chọn Next, sau đó Connect và chờ đợi nguồn và eventstream được tạo.
- Sau đó chọn Open Eventstream. Eventstream sẽ hiển thị nguồn chứng khoán và stock-data-stream trên canvas thiết kế.
Tạo Eventhouse
Eventstream nhập dữ liệu chứng khoán theo thời gian thực, nhưng hiện tại không làm gì với nó. Hãy tạo một eventhouse nơi chúng ta có thể lưu trữ dữ liệu đã thu thập trong một bảng.
- Trên thanh menu bên trái, chọn Create. Trong trang New, dưới phần Real-Time Intelligence, chọn Eventhouse. Đặt cho nó một cái tên duy nhất mà bạn chọn.
- Lưu ý nếu tùy chọn Create không được ghim trên sidebar, bạn cần chọn tùy chọn dấu ba chấm (…) trước.
- Đóng bất kỳ mẹo hoặc thông báo nào được hiển thị cho đến khi bạn thấy eventhouse trống mới của mình.
Trong bảng điều khiển bên trái, lưu ý rằng eventhouse của bạn chứa một cơ sở dữ liệu KQL với cùng tên như eventhouse. Bạn có thể tạo các bảng cho dữ liệu theo thời gian thực của mình trong cơ sở dữ liệu này hoặc tạo thêm cơ sở dữ liệu nếu cần.
Nhập Dữ liệu vào Bảng
- Chọn cơ sở dữ liệu, và lưu ý rằng có một queryset liên quan. Tệp này chứa một số truy vấn KQL mẫu mà bạn có thể sử dụng để bắt đầu truy vấn các bảng trong cơ sở dữ liệu của bạn. Tuy nhiên, hiện tại không có bảng nào để truy vấn. Hãy giải quyết vấn đề đó bằng cách đưa dữ liệu từ eventstream vào một bảng mới.
- Trong trang chính của cơ sở dữ liệu KQL của bạn, chọn Get data. Đối với nguồn dữ liệu, chọn Eventstream > Existing eventstream.
- Trong bảng chọn hoặc tạo một bảng đích, tạo một bảng mới có tên là stock. Sau đó, trong bảng cấu hình nguồn dữ liệu, chọn workspace của bạn và eventstream stock-data và đặt tên kết nối là stock-table.
- Sử dụng nút Next để hoàn tất các bước để kiểm tra dữ liệu và sau đó finish cấu hình. Đóng cửa sổ cấu hình để xem eventhouse của bạn với bảng chứng khoán. Bây giờ, kết nối giữa stream và bảng đã được tạo.
Kiểm Tra Dữ Liệu
- Trong thanh menu bên trái, chọn hub Real-Time. Trong menu … cho stream stock-data-stream, chọn Open eventstream.
- Eventstream hiện hiển thị một đích cho stream. Chọn đích trên canvas thiết kế, và nếu không có bản xem trước dữ liệu nào hiển thị bên dưới, chọn Refresh.
Trong dự án này, bạn đã tạo một eventstream rất đơn giản sẽ thu thập dữ liệu theo thời gian thực và tải nó vào một bảng. Trong một giải pháp thực tế, bạn sẽ thường thêm các biến đổi để tổng hợp dữ liệu qua các khoảng thời gian (ví dụ: để ghi lại giá trung bình của mỗi cổ phiếu trong khoảng thời gian năm phút).
Truy Vấn Dữ Liệu Đã Thu Thập
Eventstream thu thập dữ liệu thị trường chứng khoán theo thời gian thực và tải nó vào một bảng trong cơ sở dữ liệu KQL của bạn. Bạn có thể truy vấn bảng này để xem dữ liệu đã thu thập.
- Trong thanh menu bên trái, chọn cơ sở dữ liệu eventhouse của bạn.
- Chọn queryset cho cơ sở dữ liệu của bạn.
- Trong bảng truy vấn, sửa đổi truy vấn ví dụ đầu tiên như sau:
kql
stock
| take 100
- Chọn mã truy vấn và chạy nó để xem 100 dòng dữ liệu từ bảng.
- Xem xét kết quả, sau đó sửa đổi truy vấn để lấy giá trung bình cho mỗi ký hiệu cổ phiếu trong 5 phút qua:
kql
stock
| where ["time"] > ago(5m)
| summarize avgPrice = avg(todecimal(bidPrice)) by symbol
| project symbol, avgPrice
- Làm nổi bật truy vấn đã sửa đổi và chạy nó để xem kết quả. Chờ vài giây và chạy lại, lưu ý rằng giá trung bình thay đổi khi có dữ liệu mới được thêm vào bảng từ luồng thời gian thực.
Tạo Dashboard Thời gian Thực
Bây giờ bạn đã có một bảng đang được điền dữ liệu từ luồng, bạn có thể sử dụng một dashboard thời gian thực để trực quan hóa dữ liệu.
- Trong trình chỉnh sửa truy vấn, chọn truy vấn KQL mà bạn đã sử dụng để lấy giá cổ phiếu trung bình trong năm phút vừa qua.
- Trên thanh công cụ, chọn Save to dashboard. Sau đó ghim truy vấn trong một dashboard mới với các thiết lập sau:
- Tên Dashboard: Stock Dashboard
- Tên Tile: Average Prices
- Tạo dashboard và mở nó. Nó sẽ trông như thế này:
Chỉnh Sửa Dashboard
- Ở góc trên bên phải của dashboard, chuyển từ chế độ Viewing sang chế độ Editing.
- Chọn biểu tượng Edit (bút chì) cho tile Average Prices.
- Trong bảng Visual formatting, thay đổi Visual từ Table sang Column chart:
- Ở trên cùng của dashboard, chọn Apply changes và xem dashboard đã chỉnh sửa của bạn: Bây giờ bạn có một trực quan hóa trực tiếp của dữ liệu chứng khoán theo thời gian thực.
Tạo Cảnh Báo
Trí tuệ Thời gian Thực trong Microsoft Fabric bao gồm một công nghệ tên là Activator, có thể kích hoạt các hành động dựa trên các sự kiện thời gian thực. Hãy sử dụng nó để cảnh báo bạn khi giá cổ phiếu trung bình tăng lên một số lượng cụ thể.
- Trong cửa sổ dashboard chứa trực quan hóa giá cổ phiếu của bạn, trong thanh công cụ, chọn Set alert.
- Trong bảng Set alert, tạo một cảnh báo với các thiết lập sau:
- Run query every: 5 phút
- Check: Trên mỗi sự kiện được nhóm theo
- Grouping field: symbol
- When: avgPrice
- Condition: Tăng lên
- Value: 100
- Action: Gửi email cho tôi
- Save location:
- Workspace: Workspace của bạn
- Item: Tạo một mục mới
- New item name: Một tên duy nhất bạn chọn
- Tạo cảnh báo và chờ để nó được lưu. Sau đó đóng bảng xác nhận rằng nó đã được tạo.
- Trong thanh menu bên trái, chọn trang cho workspace của bạn (lưu bất kỳ thay đổi chưa lưu nào vào dashboard nếu được nhắc).
- Trên trang workspace, xem các mục bạn đã tạo trong dự án này, bao gồm activator cho cảnh báo của bạn.
- Mở activator, và trong trang của nó, dưới nút avgPrice, chọn định danh duy nhất cho cảnh báo của bạn. Sau đó xem tab History của nó. Cảnh báo của bạn có thể chưa được kích hoạt, trong trường hợp đó lịch sử sẽ không chứa dữ liệu. Nếu giá cổ phiếu trung bình bao giờ thay đổi hơn 100, activator sẽ gửi cho bạn một email và cảnh báo sẽ được ghi lại trong lịch sử.
Thực hành tốt nhất
- Luôn kiểm tra các nguồn dữ liệu trước khi kết nối.
- Đặt tên rõ ràng cho các bảng và eventstream để dễ quản lý.
- Thường xuyên theo dõi hiệu suất của dashboard.
Những cạm bẫy thường gặp
- Bỏ qua việc cấu hình cảnh báo có thể dẫn đến thiếu thông tin quan trọng.
- Không tối ưu hóa truy vấn KQL có thể làm chậm quá trình phân tích dữ liệu.
Mẹo hiệu suất
- Sử dụng các chỉ số để cải thiện tốc độ truy vấn.
- Tối ưu hóa cấu trúc bảng để giảm thiểu thời gian truy xuất dữ liệu.
Giải quyết sự cố
- Nếu không thấy dữ liệu trong bảng, kiểm tra kết nối với eventstream.
- Kiểm tra lại cấu hình của các cảnh báo để đảm bảo chúng hoạt động chính xác.
Kết luận
Trong bài viết này, bạn đã tìm hiểu cách sử dụng Trí tuệ Thời gian Thực trong Microsoft Fabric để tạo ra một giải pháp phân tích dữ liệu thị trường chứng khoán theo thời gian thực. Hãy tiếp tục khám phá và cải tiến các giải pháp của bạn với Microsoft Fabric để tăng cường khả năng phân tích và trực quan hóa dữ liệu.
FAQ
- Trí tuệ Thời gian Thực là gì?
- Là khả năng phân tích và xử lý dữ liệu theo thời gian thực trong Microsoft Fabric.
- Làm thế nào để tạo một dashboard?
- Sử dụng các truy vấn KQL để trực quan hóa dữ liệu và lưu lại dưới dạng dashboard.
Hãy bắt đầu ngay hôm nay và tối ưu hóa quy trình phân tích dữ liệu của bạn với Microsoft Fabric!