先决条件
要从中读取内容的 Blackbaud Raiser Edge NXT 对象。您将需要对象名称。
源支持的实体:
实体 | 可以筛选 | 支持限制 | 支持排序依据 | 支持 Select * | 支持分区 |
---|---|---|---|---|---|
Constituent Address | 支持 | 是 | 否 | 是 | 是 |
Constituent Education | 支持 | 是 | 否 | 是 | 是 |
Constituent Email address | 支持 | 是 | 否 | 是 | 是 |
Constituent Phone | 支持 | 是 | 否 | 是 | 是 |
Constituent Note | 支持 | 是 | 否 | 是 | 是 |
Constituent Relationship | 支持 | 是 | 否 | 是 | 是 |
Constituent Online presence | 支持 | 是 | 否 | 是 | 是 |
机会 | 是 | 是 | 否 | 是 | 是 |
Appeal | 支持 | 是 | 否 | 是 | 是 |
活动 | 支持 | 是 | 否 | 是 | 是 |
Fund | 支持 | 是 | 否 | 是 | 是 |
软件包 | 支持 | 是 | 否 | 是 | 是 |
Gift Batch | 支持 | 是 | 否 | 是 | 否 |
Event Participant | 支持 | 是 | 是 | 是 | 是 |
Constituent Fundraiser Assignment | 否 | 否 | 否 | 是 | 否 |
Gift | 支持 | 是 | 是 | 是 | 是 |
成员身份 | 支持 | 是 | 否 | 是 | 是 |
操作 | 支持 | 是 | 否 | 是 | 否 |
Constituent | 支持 | 是 | 是 | 是 | 是 |
Constituent Goods | 支持 | 是 | 否 | 是 | 是 |
事件 | 支持 | 是 | 是 | 是 | 是 |
Gift custom field | 支持 | 是 | 否 | 是 | 是 |
示例:
blackbaud_read = glueContext.create_dynamic_frame.from_options(
connection_type="BLACKBAUD",
connection_options={
"connectionName": "connectionName",
"ENTITY_NAME": "entityName",
"API_VERSION": "v1",
"SUBSCRIPTION_KEY": <Subscription key associated with one's developer account>
}
Blackbaud Raiser Edge NXT 实体和字段详细信息
有关实体和字段详细信息的更多信息,请参阅:
注意
在连接器的响应中,“结构体”和“列表”数据类型将转换为“字符串”数据类型,“日期时间”数据类型将转换为“时间戳”数据类型。
对查询进行分区
基于字段的分区:
Blackbaud Raiser Edge NXT 不支持基于字段的分区或基于记录的分区。
基于记录的分区:
如果您想在 Spark 中利用并发,可以提供附加 Spark 选项 NUM_PARTITIONS
。使用此参数,原始查询将被拆分为 NUM_PARTITIONS
个子查询,这些子查询可以由 Spark 任务同时执行。
在基于记录的分区中,从 Blackbaud Raiser Edge NXT API 查询存在的记录总数,然后将其除以提供的 NUM_PARTITIONS
数字。然后,每个子查询会同时获取生成的记录数。
NUM_PARTITIONS
:分区的数量。
示例:
blackbaud_read = glueContext.create_dynamic_frame.from_options(
connection_type="BLACKBAUD",
connection_options={
"connectionName": "connectionName",
"ENTITY_NAME": "entityName",
"API_VERSION": "v1",
"NUM_PARTITIONS": "2",
"SUBSCRIPTION_KEY": <Subscription key associated with one's developer account>
}