本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。
先決條件
-
您要讀取的管道驅動物件。請參閱以下支援的實體資料表，以檢查可用的實體。
支援的實體
| 實體 | 可以篩選 | 支援限制 | 支援 排序依據 | 支援選取 * | 支援分割 |
|---|---|---|---|---|---|
| 活動 | 是 | 是 | 否 | 是 | 是 |
| 活動類型 | 否 | 否 | 否 | 是 | 否 |
| 通話日誌 | 否 | 否 | 否 | 是 | 否 |
| 貨幣 | 是 | 是 | 否 | 是 | 否 |
| 交易 | 是 | 是 | 是 | 是 | 是 |
| 潛在客戶 | 是 | 是 | 是 | 是 | 否 |
| 潛在客戶來源 | 否 | 是 | 否 | 是 | 否 |
| 潛在客戶標籤 | 否 | 否 | 否 | 否 | 否 |
| 備註 | 是 | 是 | 是 | 是 | 是 |
| 組織 | 是 | 是 | 否 | 是 | 是 |
| 許可集 | 是 | 否 | 否 | 是 | 否 |
| 人物 | 是 | 是 | 是 | 是 | 是 |
| 管道 | 否 | 是 | 否 | 是 | 否 |
| 產品 | 是 | 是 | 否 | 是 | 是 |
| 角色 | 否 | 是 | 否 | 是 | 否 |
| 階段 | 是 | 是 | 否 | 是 | 否 |
| 使用者 | 否 | 否 | 否 | 是 | 否 |
範例
pipedrive_read= glueContext.create_dynamic_frame.from_options(
connection_type="PIPEDRIVE",
connection_options={
"connectionName": "connectionName",
"ENTITY_NAME": "activites",
"API_VERSION": "v1"
}Pipedrive 實體和欄位詳細資訊
實體清單：
-
活動：https：//https://developers.pipedrive.com/docs/api/v1/Activities
-
活動類型：https：//https://developers.pipedrive.com/docs/api/v1/ActivityTypes
-
通話日誌：https：//https://developers.pipedrive.com/docs/api/v1/CallLogs
-
貨幣：https：//https://developers.pipedrive.com/docs/api/v1/Currencies
-
優惠：https：//https://developers.pipedrive.com/docs/api/v1/Deals
-
潛在客戶：https：//https://developers.pipedrive.com/docs/api/v1/Leads
-
主要來源：https：//https://developers.pipedrive.com/docs/api/v1/LeadSources
-
潛在客戶標籤：https：//https://developers.pipedrive.com/docs/api/v1/LeadLabels
-
備註：https：//https://developers.pipedrive.com/docs/api/v1/Notes
-
組織：https：//https://developers.pipedrive.com/docs/api/v1/Organizations
-
許可集：https：//https://developers.pipedrive.com/docs/api/v1/PermissionSets
-
人員：https：//https://developers.pipedrive.com/docs/api/v1/Persons
-
管道：https：//https://developers.pipedrive.com/docs/api/v1/Pipelines
-
產品：https：//https://developers.pipedrive.com/docs/api/v1/Products
-
角色：https：//https://developers.pipedrive.com/docs/api/v1/Roles
-
階段：https：//https://developers.pipedrive.com/docs/api/v1/Stages
-
使用者：https：//https://developers.pipedrive.com/docs/api/v1/Users
| 實體 | 資料類型 | 支援的運算子 |
|---|---|---|
| 活動、交易、備註、組織、人員和產品。 | 日期 | '=' |
| Integer | '=' | |
| 字串 | '=' | |
| Boolean | '=' |
分割查詢
在 Pipedrive 中，只有來自活動實體的一個欄位 (due_date) 支援以欄位為基礎的分割。這是日期欄位。
如果您想要在 Spark 中使用並行PARTITION_FIELD，NUM_PARTITIONS可以提供其他的 Spark LOWER_BOUND選項 UPPER_BOUND、、。透過這些參數，原始查詢會分割為可由 Spark 任務同時執行的子查詢NUM_PARTITIONS數目。
-
PARTITION_FIELD：用於分割查詢的欄位名稱。 -
LOWER_BOUND：所選分割區欄位的包含下限值。對於日期，我們接受 Spark SQL 查詢中使用的 Spark 日期格式。有效值的範例：
"2024-02-06"。 -
UPPER_BOUND：所選分割區欄位的專屬上限值。 -
NUM_PARTITIONS：分割區數量。
範例
pipedrive_read = glueContext.create_dynamic_frame.from_options(
connection_type="PIPEDRIVE",
connection_options={
"connectionName": "connectionName",
"ENTITY_NAME": "activites",
"API_VERSION": "v1",
"PARTITION_FIELD": "due_date"
"LOWER_BOUND": "2023-09-07T02:03:00.000Z"
"UPPER_BOUND": "2024-05-07T02:03:00.000Z"
"NUM_PARTITIONS": "10"
}