`airflow.providers.google.cloud.operators.stackdriver`¶

Module Contents¶

Classes¶

`StackdriverListAlertPoliciesOperator`	Fetches all the Alert Policies identified by the filter passed as
`StackdriverEnableAlertPoliciesOperator`	Enables one or more disabled alerting policies identified by filter
`StackdriverDisableAlertPoliciesOperator`	Disables one or more enabled alerting policies identified by filter
`StackdriverUpsertAlertOperator`	Creates a new alert or updates an existing policy identified
`StackdriverDeleteAlertOperator`	Deletes an alerting policy.
`StackdriverListNotificationChannelsOperator`	Fetches all the Notification Channels identified by the filter passed as
`StackdriverEnableNotificationChannelsOperator`	Enables one or more disabled alerting policies identified by filter
`StackdriverDisableNotificationChannelsOperator`	Disables one or more enabled notification channels identified by filter
`StackdriverUpsertNotificationChannelOperator`	Creates a new notification or updates an existing notification channel
`StackdriverDeleteNotificationChannelOperator`	Deletes a notification channel.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverListAlertPoliciesOperator(*, format_=None, filter_=None, order_by=None, page_size=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Fetches all the Alert Policies identified by the filter passed as filter parameter. The desired return type can be specified by the format parameter, the supported formats are "dict", "json" and None which returns python dictionary, stringified JSON and protobuf respectively.

See also

For more information on how to use this operator, take a look at the guide: StackdriverListAlertPoliciesOperator

Parameters

format -- (Optional) Desired output format of the result. The supported formats are "dict", "json" and None which returns python dictionary, stringified JSON and protobuf respectively.
filter -- If provided, this field specifies the criteria that must be met by alert policies to be included in the response. For more details, see https://cloud.google.com/monitoring/api/v3/sorting-and-filtering.
order_by (Optional[str]) -- A comma-separated list of fields by which to sort the result. Supports the same set of field references as the filter field. Entries can be prefixed with a minus sign to sort by the field in descending order. For more details, see https://cloud.google.com/monitoring/api/v3/sorting-and-filtering.
page_size (Optional[int]) -- The maximum number of resources contained in the underlying API response. If page streaming is performed per- resource, this parameter does not affect the return value. If page streaming is performed per-page, this determines the maximum number of resources in a page.
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The project to fetch alerts from.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields :Sequence[str] = ['filter_', 'impersonation_chain'][source]¶

operator_extra_links[source]¶

ui_color = #e5ffcc[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverEnableAlertPoliciesOperator(*, filter_=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Enables one or more disabled alerting policies identified by filter parameter. Inoperative in case the policy is already enabled.

See also

For more information on how to use this operator, take a look at the guide: StackdriverEnableAlertPoliciesOperator

Parameters

filter -- If provided, this field specifies the criteria that must be met by alert policies to be enabled. For more details, see https://cloud.google.com/monitoring/api/v3/sorting-and-filtering.
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The project in which alert needs to be enabled.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

ui_color = #e5ffcc[source]¶

template_fields :Sequence[str] = ['filter_', 'impersonation_chain'][source]¶

operator_extra_links[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverDisableAlertPoliciesOperator(*, filter_=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Disables one or more enabled alerting policies identified by filter parameter. Inoperative in case the policy is already disabled.

See also

For more information on how to use this operator, take a look at the guide: StackdriverDisableAlertPoliciesOperator

Parameters

filter -- If provided, this field specifies the criteria that must be met by alert policies to be disabled. For more details, see https://cloud.google.com/monitoring/api/v3/sorting-and-filtering.
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The project in which alert needs to be disabled.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

ui_color = #e5ffcc[source]¶

template_fields :Sequence[str] = ['filter_', 'impersonation_chain'][source]¶

operator_extra_links[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverUpsertAlertOperator(*, alerts, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Creates a new alert or updates an existing policy identified the name field in the alerts parameter.

See also

For more information on how to use this operator, take a look at the guide: StackdriverUpsertAlertOperator

Parameters

alerts (str) -- A JSON string or file that specifies all the alerts that needs to be either created or updated. For more details, see https://cloud.google.com/monitoring/api/ref_v3/rest/v3/projects.alertPolicies#AlertPolicy. (templated)
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The project in which alert needs to be created/updated.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields :Sequence[str] = ['alerts', 'impersonation_chain'][source]¶

template_ext :Sequence[str] = ['.json'][source]¶

operator_extra_links[source]¶

ui_color = #e5ffcc[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverDeleteAlertOperator(*, name, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Deletes an alerting policy.

See also

For more information on how to use this operator, take a look at the guide: StackdriverDeleteAlertOperator

Parameters

name (str) -- The alerting policy to delete. The format is: projects/[PROJECT_ID]/alertPolicies/[ALERT_POLICY_ID].
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The project from which alert needs to be deleted.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields :Sequence[str] = ['name', 'impersonation_chain'][source]¶

ui_color = #e5ffcc[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverListNotificationChannelsOperator(*, format_=None, filter_=None, order_by=None, page_size=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Fetches all the Notification Channels identified by the filter passed as filter parameter. The desired return type can be specified by the format parameter, the supported formats are "dict", "json" and None which returns python dictionary, stringified JSON and protobuf respectively.

See also

For more information on how to use this operator, take a look at the guide: StackdriverListNotificationChannelsOperator

Parameters

format -- (Optional) Desired output format of the result. The supported formats are "dict", "json" and None which returns python dictionary, stringified JSON and protobuf respectively.
filter -- If provided, this field specifies the criteria that must be met by notification channels to be included in the response. For more details, see https://cloud.google.com/monitoring/api/v3/sorting-and-filtering.
order_by (Optional[str]) -- A comma-separated list of fields by which to sort the result. Supports the same set of field references as the filter field. Entries can be prefixed with a minus sign to sort by the field in descending order. For more details, see https://cloud.google.com/monitoring/api/v3/sorting-and-filtering.
page_size (Optional[int]) -- The maximum number of resources contained in the underlying API response. If page streaming is performed per- resource, this parameter does not affect the return value. If page streaming is performed per-page, this determines the maximum number of resources in a page.
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The project to fetch notification channels from.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields :Sequence[str] = ['filter_', 'impersonation_chain'][source]¶

operator_extra_links[source]¶

ui_color = #e5ffcc[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverEnableNotificationChannelsOperator(*, filter_=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Enables one or more disabled alerting policies identified by filter parameter. Inoperative in case the policy is already enabled.

See also

For more information on how to use this operator, take a look at the guide: StackdriverEnableNotificationChannelsOperator

Parameters

filter -- If provided, this field specifies the criteria that must be met by notification channels to be enabled. For more details, see https://cloud.google.com/monitoring/api/v3/sorting-and-filtering.
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The location used for the operation.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields :Sequence[str] = ['filter_', 'impersonation_chain'][source]¶

operator_extra_links[source]¶

ui_color = #e5ffcc[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverDisableNotificationChannelsOperator(*, filter_=None, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Disables one or more enabled notification channels identified by filter parameter. Inoperative in case the policy is already disabled.

See also

For more information on how to use this operator, take a look at the guide: StackdriverDisableNotificationChannelsOperator

Parameters

filter -- If provided, this field specifies the criteria that must be met by alert policies to be disabled. For more details, see https://cloud.google.com/monitoring/api/v3/sorting-and-filtering.
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The project in which notification channels needs to be enabled.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields :Sequence[str] = ['filter_', 'impersonation_chain'][source]¶

operator_extra_links[source]¶

ui_color = #e5ffcc[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverUpsertNotificationChannelOperator(*, channels, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Creates a new notification or updates an existing notification channel identified the name field in the alerts parameter.

See also

For more information on how to use this operator, take a look at the guide: StackdriverUpsertNotificationChannelOperator

Parameters

channels (str) -- A JSON string or file that specifies all the alerts that needs to be either created or updated. For more details, see https://cloud.google.com/monitoring/api/ref_v3/rest/v3/projects.notificationChannels. (templated)
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The project in which notification channels needs to be created/updated.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields :Sequence[str] = ['channels', 'impersonation_chain'][source]¶

template_ext :Sequence[str] = ['.json'][source]¶

operator_extra_links[source]¶

ui_color = #e5ffcc[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.google.cloud.operators.stackdriver.StackdriverDeleteNotificationChannelOperator(*, name, retry=DEFAULT, timeout=None, metadata=(), gcp_conn_id='google_cloud_default', project_id=None, delegate_to=None, impersonation_chain=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Deletes a notification channel.

See also

For more information on how to use this operator, take a look at the guide: StackdriverDeleteNotificationChannelOperator

Parameters

name (str) -- The alerting policy to delete. The format is: projects/[PROJECT_ID]/notificationChannels/[CHANNEL_ID].
retry (Union[google.api_core.retry.Retry, google.api_core.gapic_v1.method._MethodDefault]) -- A retry object used to retry requests. If None is specified, requests will be retried using a default configuration.
timeout (Optional[float]) -- The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadata (Sequence[Tuple[str, str]]) -- Additional metadata that is provided to the method.
gcp_conn_id (str) -- (Optional) The connection ID used to connect to Google Cloud Platform.
project_id (Optional[str]) -- The project from which notification channel needs to be deleted.
delegate_to (Optional[str]) -- The account to impersonate using domain-wide delegation of authority, if any. For this to work, the service account making the request must have domain-wide delegation enabled.
impersonation_chain (Optional[Union[str, Sequence[str]]]) -- Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token of the last account in the list, which will be impersonated in the request. If set as a string, the account must grant the originating account the Service Account Token Creator IAM role. If set as a sequence, the identities from the list must grant Service Account Token Creator IAM role to the directly preceding identity, with first account from the list granting this role to the originating account (templated).

template_fields :Sequence[str] = ['name', 'impersonation_chain'][source]¶

ui_color = #e5ffcc[source]¶

execute(self, context)[source]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

airflow.providers.google.cloud.operators.stackdriver¶

Module Contents¶

Classes¶

`airflow.providers.google.cloud.operators.stackdriver`¶