嗨@Sanjay_AMP
三角洲生活表和自動裝卸機可以一起使用增量地攝取來自雲對象存儲的數據。
•Python代碼示例:
——定義一個表稱為“顧客”,從CSV文件中讀取數據beplay体育app下载地址對象存儲在雲。
——定義一個表稱為“sales_orders_raw”,從JSON文件中讀取數據對象存儲在雲。
•SQL代碼示例:
——創建或刷新流表稱為“顧客”,選擇所有的數據從一個CSV文件雲存儲對象。beplay体育app下载地址
——創建或刷新流表稱為“sales_orders_raw”從JSON文件選擇所有數據對象存儲在雲。
•可以傳遞到選項cloud_files ()方法使用map ()函數。
•模式可以為指定格式不支持模式推理。
•額外的代碼示例和文檔可以在提供的來源。
@dlt。表def客戶():返beplay体育app下载地址回(spark.readStream.format .option (“cloudFiles (“cloudFiles”)。”、“csv格式”).load (/ databricks-datasets / retail-org客戶/)beplay体育app下载地址)@dlt。表def sales_orders_raw():返回(spark.readStream.format .option (“cloudFiles (“cloudFiles”)。”、“json格式”).load (" / databricks-datasets / retail-org sales_orders / "))
