flexget.plugins.output.sns module

class flexget.plugins.output.sns.SNSNotification

Bases: object

Emits SNS notifications of entries.

Optionally writes the torrent itself to S3

Example configuration:

sns:
  [aws_access_key_id: <AWS ACCESS KEY ID>] (will be taken from AWS_ACCESS_KEY_ID environment if not provided)
  [aws_secret_access_key: <AWS SECRET ACCESS KEY>] (will be taken from AWS_SECRET_ACCESS_KEY environment if
      not provided)
  [profile_name: <AWS PROFILE NAME>] (If provided, use this profile name instead of the default.)
  aws_region: <REGION>
  sns_topic_arn: <SNS ARN>
  [sns_notification_template: <TEMPLATE] (defaults to DEFAULT_TEMPLATE_VALUE)

on_task_output(task, config)

on_task_start(task, config)

schema = {'additionalProperties': False, 'properties': {'aws_access_key_id': {'type': 'string'}, 'aws_region': {'type': 'string'}, 'aws_secret_access_key': {'type': 'string'}, 'profile_name': {'type': 'string'}, 'sns_notification_template': {'default': '{"entry": {"title": "{{title}}", "url": "{{url}}", "original_url": "{{original_url}}", "series": "{{series_name}}", "series_id": "{{series_id}}"}, "task": "{{task}}"}', 'type': 'string'}, 'sns_topic_arn': {'type': 'string'}}, 'required': ['sns_topic_arn', 'aws_region'], 'type': 'object'}

class flexget.plugins.output.sns.SNSNotificationEmitter(config)

Bases: object

build_session()

get_topic()

send_notifications(task)

flexget.plugins.output.sns.register_sns_plugin()