DBMS_CLOUD_NOTIFICATION 程序包
DBMS_CLOUD_NOTIFICATION 软件包允许您向提供程序发送消息或 SQL 查询的输出。
支持 DBMS_CLOUD_NOTIFICATION 的提供商包括:电子邮件、Microsoft Teams、OCI 通知 (ONS) 和 Slack。
将 OCI Notifications 服务与 DBMS_CLOUD_NOTIFICATION 程序包结合使用时,仅支持 DBMS_CLOUD_NOTIFICATION.SEND_MESSAGE 过程(不支持 DBMS_CLOUD_NOTIFICATION.SEND_DATA 过程)。
先决条件
- 按照 Oracle Cloud Infrastructure 文档中的创建 NAT 网关中的说明,在虚拟云网络 (VCN) 中创建 Autonomous AI Database 资源所在的 NAT 网关。
- 创建 NAT 网关后,向每个子网添加路由规则和出站安全规则(在 VCN 中),自治 AI 数据库资源位于该子网中,以便这些资源可以使用网关从 Azure AD 实例获取公钥:
- 转到子网的子网详细信息页。
- 在子网信息选项卡中,单击子网的路由表的名称以显示其路由表详细信息页。
- 在现有路由规则表中,检查是否已存在具有以下特征的规则:
- 目标:0.0.0.0/0
- 目标类型:NAT 网关
- 目标:刚在 VCN 中创建的 NAT 网关的名称
如果不存在此类规则,请单击添加路由规则并添加具有这些特征的路由规则。
- 返回到子网的子网详细信息页。
- 在子网的安全列表表中,单击子网的安全列表的名称以显示其安全列表详细信息页。
- 在侧边菜单的资源下,单击出站规则。
- 在现有出站规则表中,检查是否已存在具有以下特征的规则:
- 目标类型: CIDR
- 目标:0.0.0.0/0
- IP 协议: TCP
- 源端口范围: 443
- 目标端口范围:全部
如果不存在此类规则,请单击添加出站规则并添加具有这些特征的出站规则。
环境中的 HTTP 代理设置必须允许数据库访问云服务提供商。
注意:
只有在 Exadata 基础结构处于 Requires Activation 状态之前,才能编辑包括 HTTP 代理的网络配置。一旦激活,就无法编辑这些设置。为已预配的 Exadata 基础结构设置 HTTP 代理需要在 My Oracle Support 中创建服务请求 (SR)。有关详细信息,请参见在 My Oracle Support 中创建服务请求。
SEND_DATA 过程
SEND_DATA 过程将指定查询的结果发送到提供程序。
语法
DBMS_CLOUD_NOTIFICATION.SEND_DATA(
provider IN VARCHAR2,
credential_name IN VARCHAR2,
query IN CLOB,
params IN CLOB
);
参数
| Parameter (参数) | 说明 |
|---|---|
|
|
指定提供者。 有效值为:' 此参数是必需的。 |
|
|
用于访问提供程序的身份证明对象的名称。 对于电子邮件提供商,凭证是 SMTP 批准发件人的凭证名称,其中包含其用户名和密码。 对于 msteams 提供方,该身份证明是身份证明的名称。 对于 Slack 提供程序,凭证的用户名必须为 此参数是必需的。 |
|
|
指定要运行的 SQL 查询。结果将发送到提供商。 此参数是必需的。 |
|
|
以 JSON 格式指定 对于提供者类型
对于提供者类型
对于提供者类型
此参数是必需的。 |
使用说明
使用 DBMS_CLOUD.CREATE_CREDENTIAL(credential_name、username、password) 过程创建凭证对象。有关更多信息,请参见CREATE_CREDENTIAL Procedure 。
- 对于
email提供者,用户需要 SMTP 连接端点,电子邮件传送服务器才能获取smtp_host。用户还需要 SMTP 批准的发件人及其身份证明才能通过电子邮件传送服务器进行验证以获取credential_name。必须配置 SMTP 连接,并且必须生成和批准 SMTP 凭证。 - 对于
msteams提供程序,用户需要 Microsoft Teams 应用程序以及其中配置的机器人。该应用程序需要在管理员从管理中心获得批准后发布到组织并安装。用户还需要从其 Azure 门户访问 Graph API 的Files.ReadWrite.All和ChannelSettings.Read.All权限。要生成所需的令牌,用户需要用户名中的bot_id和密码中的bot_secret。对 Microsoft Teams 使用DBMS_CLOUD_NOTIFICATION.SEND_DATA时支持的最大文件大小为 4MB。 - 对于
slack提供方,username值可以是任何有效字符串,password是 Slack 机器人标记。
范例
使用 email 提供程序发送 SQL 输出:
BEGIN
DBMS_CLOUD.CREATE_CREDENTIAL(
credential_name => 'EMAIL_CRED',
username => 'username',
password => 'password');
END;
/
BEGIN
DBMS_CLOUD_NOTIFICATION.SEND_DATA(
provider => 'email',
credential_name => 'EMAIL_CRED',
query => 'SELECT tablespace_name FROM dba_tablespaces',
params => json_object('recipient' value 'mark@oracle.com, suresh@oracle.com',
'to_cc' value 'nicole@oracle.com1, jordan@oracle.com',
'to_bcc' value 'manisha@oracle.com',
'subject' value 'Test subject',
'type' value 'json',
'title' value 'mytitle',
'message' value 'This is the message',
'smtp_host' value 'smtp.email.example.com',
'sender' value 'approver_sender@oracle.com' )
);
END;
/使用 msteams 提供程序发送 SQL 输出:
BEGIN
DBMS_CLOUD.CREATE_CREDENTIAL(credential_name => 'TEAMS_CRED',
username => 'bot_id',
password => 'bot_secret');
END;
/
BEGIN
DBMS_CLOUD_NOTIFICATION.SEND_MESSAGE(provider => 'msteams',
credential_name => 'TEAMS_CRED',
query => 'SELECT tablespace_name FROM dba_tablespaces',
params => json_object('tenant'value '5b743bc******c0286',
'team'value '0ae401*********5d2bd',
'channel'value '19%3a94be023*****%40thread.tacv2',
'title'value 'today',
'type'value 'csv'));
END;
/
使用 slack 提供程序发送 SQL 输出:
BEGIN
DBMS_CLOUD.CREATE_CREDENTIAL(
credential_name => 'SLACK_CRED',
username => 'SLACK_TOKEN',
password => 'password');
END;
/
BEGIN
DBMS_CLOUD_NOTIFICATION.SEND_DATA(
provider => 'slack',
credential_name => 'SLACK_CRED',
query => 'SELECT username, account_status, expiry_date FROM USER_USERS WHERE rownum < 5',
params => json_object('channel' value 'C0....08','type' value 'csv'));
END;
/
SEND_MESSAGE 过程
该过程将向提供商发送短信。
语法
DBMS_CLOUD_NOTIFICATION.SEND_MESSAGE(
provider IN VARCHAR2,
credential_name IN VARCHAR2,
message IN CLOB,
params IN CLOB
);
参数
| Parameter (参数) | 说明 |
|---|---|
|
|
指定提供者。 有效值包括:' 此参数是必需的。 |
|
|
用于访问提供程序的身份证明对象的名称。 对于电子邮件提供商,凭证是 SMTP 批准发件人的凭证名称,其中包含其用户名和密码。 对于 msteams 提供者,凭证必须在用户名和密码中包含 对于 Slack 提供程序,凭证的用户名必须为 对于 此参数是必需的。 |
|
|
指定消息文本。 此参数是必需的。 |
|
|
以 JSON 格式指定 对于提供者类型
email,有效参数为:
对于提供方类型
msteams,有效参数为:
对于提供方类型
slack,有效参数为:
对于类型为
oci 的提供商 OCI Notifications,有效参数为:
使用
oci 提供程序时,消息可能有不同的端点,具体取决于订阅。对于不同的订阅,title 参数的处理方式不同:
渠道 ID 是渠道的唯一 ID,与渠道名称不同。在 Slack 中,当您查看渠道详细信息时,可以在“About(关于)”选项卡上找到渠道 ID。 此参数是必需的。 |
使用说明
使用过程 DBMS_CLOUD.CREATE_CREDENTIAL(credential_name、username、password) 创建凭证对象。有关更多信息,请参见CREATE_CREDENTIAL Procedure 。
- 对于
email提供者,用户需要 SMTP 连接端点,电子邮件传送服务器才能获取smtp_host。用户还需要 SMTP 批准的发件人及其身份证明才能通过电子邮件传送服务器进行验证以获取credential_name。必须配置 SMTP 连接,并且必须生成和批准 SMTP 凭证。 - 对于
msteams提供程序,用户需要 Microsoft Teams 应用程序以及其中配置的机器人。该应用程序需要在管理员从管理中心获得批准后发布到组织并安装。用户还需要从其 Azure 门户访问 Graph API 的Files.ReadWrite.All和ChannelSettings.Read.All权限。要生成所需的令牌,用户需要用户名中的bot_id和密码中的bot_secret。 - 对于
slack提供方,username值可以是任何有效字符串,password是 Slack 机器人标记。 -
DBMS_CLOUD_NOTIFICATION支持 OCI Notifications 提供商。有关 OCI 通知提供商的详细信息,请参阅通知概述。- 要使用 OCI Notifications 提供程序,您必须执行以下操作:
- 创建主题。有关创建主题的详细信息,请参阅创建主题
- 创建必需的订阅。有关创建订阅的详细信息,请参阅创建订阅。
- 创建订阅后,请确认订阅。消息仅发布到已确认的订阅。有关确认订阅的详细信息,请参见 Confirming a Subscription 。
- Autonomous AI Database 实例、身份证明(如果您使用的是用户身份证明)和订阅主题必须都位于同一区域中。
- 请注意以下限制:
- 消息大小限制:每个请求的消息大小限制为 64KB。不能在单个请求内发送或处理超过此大小的消息。
- 消息传送速率限制:根据使用的协议,消息传送速率限制不同。
email协议:限制为每个端点每分钟 10 条消息。
此限制可能会影响消息的传输和接收速度。
- 每分钟事务处理 (Transactions Per Minute,TPM) 限制:此操作的每个主题的 TPM 限制为 60。此限制表示可以针对给定主题处理或处理的最大每分钟消息数。超过此限制可能会导致消息未以较慢的速度进行处理或处理。
- 要使用 OCI Notifications 提供程序,您必须执行以下操作:
示例
使用 email 提供程序发送文本消息:
BEGIN
DBMS_CLOUD.CREATE_CREDENTIAL(
credential_name => 'EMAIL_CRED',
username => 'username',
password => 'password');
END;
/
BEGIN
DBMS_CLOUD_NOTIFICATION.SEND_MESSAGE(
provider => 'email',
credential_name => 'EMAIL_CRED',
message => 'Subject content',
params => json_object('recipient' value 'mark@oracle.com, suresh@oracle.com',
'to_cc' value 'nicole@oracle.com, jordan@oracle.com',
'to_bcc' value 'manisha@oracle.com',
'subject' value 'Test subject',
'smtp_host' value 'smtp.email.example.com',
'sender' value 'approver_sender@oracle.com' )
);
END;
/使用 msteams 提供程序发送文本消息:
BEGIN
DBMS_CLOUD.CREATE_CREDENTIAL(credential_name => 'TEAMS_CRED',
username => 'bot_id',
password => 'bot_secret');
END;
/
BEGIN
DBMS_CLOUD_NOTIFICATION.SEND_MESSAGE(
provider => 'msteams',
credential_name => 'TEAMS_CRED',
message => 'text from new teams api',
params => json_object('channel'value 'C0....08'),'region'value 'india');
END;
/
使用 slack 提供程序发送文本消息:
BEGIN
DBMS_CLOUD.CREATE_CREDENTIAL(
credential_name => 'SLACK_CRED',
username => 'SLACK_TOKEN',
password => 'password');
END;
/
BEGIN
DBMS_CLOUD_NOTIFICATION.SEND_MESSAGE(
provider => 'slack',
credential_name => 'SLACK_CRED',
message => 'Send text from Autonomous AI Database.',
params => json_object('channel' value 'C0....08'));
END;
/
向 OCI Notifications 发送一条短信,键入 oci Provider:
BEGIN
DBMS_CLOUD_NOTIFICATION.SEND_MESSAGE(
provider => 'oci',
credential_name => 'OCI_CRED',
message => 'Text message for you.',
params => json_object('topic_ocid' value 'oci********pa',
'title' value 'Title for message subject' ));
END;
/