feat: add Redis connector

connectors/migrations/0034_alter_connector_connector_type_and_more.py

@@ -0,0 +1,33 @@
+# Generated by Django 4.1.13 on 2026-09-11 04:46
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('connectors', '0033_alter_connector_connector_type_and_more'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='connector',
+            name='connector_type',
+            field=models.IntegerField(blank=True, choices=[(0, 'UNKNOWN'), (1, 'SENTRY'), (2, 'SEGMENT'), (3, 'ELASTIC_SEARCH'), (4, 'AMPLITUDE'), (5, 'AWS_KINESIS'), (6, 'CLOUDWATCH'), (7, 'CLEVERTAP'), (8, 'RUDDERSTACK'), (9, 'MOENGAGE'), (10, 'CRIBL'), (11, 'KAFKA'), (12, 'DATADOG'), (13, 'FILEBEAT'), (14, 'LOGSTASH'), (15, 'FLUENTD'), (16, 'FLUENTBIT'), (17, 'PAGER_DUTY'), (18, 'NEW_RELIC'), (19, 'SLACK'), (20, 'HONEYBADGER'), (21, 'GOOGLE_CHAT'), (22, 'DATADOG_OAUTH'), (23, 'GCM'), (24, 'PROMETHEUS'), (25, 'ELASTIC_APM'), (26, 'VICTORIA_METRICS'), (27, 'SLACK_CONNECT'), (28, 'GRAFANA'), (29, 'CLICKHOUSE'), (30, 'DOCUMENTATION'), (31, 'POSTGRES'), (32, 'OPS_GENIE'), (33, 'EKS'), (34, 'AGENT_PROXY'), (35, 'GRAFANA_VPC'), (36, 'GITHUB'), (37, 'SQL_DATABASE_CONNECTION'), (38, 'OPEN_AI'), (39, 'REMOTE_SERVER'), (40, 'API'), (41, 'BASH'), (42, 'AZURE'), (43, 'GRAFANA_MIMIR'), (44, 'GKE'), (45, 'MS_TEAMS'), (46, 'GRAFANA_LOKI'), (47, 'KUBERNETES'), (48, 'SMTP'), (49, 'BIG_QUERY'), (50, 'ZENDUTY'), (51, 'ROOTLY'), (52, 'JIRA_CLOUD'), (53, 'ASANA'), (54, 'CONFLUENCE_CLOUD'), (55, 'CONFLUENCE_SELF_HOSTED'), (56, 'GOOGLE_DRIVE'), (57, 'NOTION'), (58, 'DRD_PROXY_AGENT'), (59, 'MONGODB'), (60, 'OPEN_SEARCH'), (61, 'LINEAR'), (62, 'JENKINS'), (63, 'GITHUB_ACTIONS'), (65, 'ARGOCD'), (66, 'REDIS')], default=0, null=True),
+        ),
+        migrations.AlterField(
+            model_name='connectorkey',
+            name='key_type',
+            field=models.IntegerField(blank=True, choices=[(0, 'UNKNOWN_SKT'), (1, 'SENTRY_API_KEY'), (6, 'SENTRY_ORG_SLUG'), (2, 'DATADOG_APP_KEY'), (3, 'DATADOG_API_KEY'), (15, 'DATADOG_AUTH_TOKEN'), (18, 'DATADOG_API_DOMAIN'), (4, 'NEWRELIC_API_KEY'), (5, 'NEWRELIC_APP_ID'), (7, 'NEWRELIC_QUERY_KEY'), (19, 'NEWRELIC_API_DOMAIN'), (8, 'SLACK_BOT_AUTH_TOKEN'), (9, 'SLACK_CHANNEL_ID'), (46, 'SLACK_APP_ID'), (10, 'HONEYBADGER_USERNAME'), (11, 'HONEYBADGER_PASSWORD'), (12, 'HONEYBADGER_PROJECT_ID'), (13, 'AWS_ACCESS_KEY'), (14, 'AWS_SECRET_KEY'), (20, 'AWS_REGION'), (23, 'AWS_ASSUMED_ROLE_ARN'), (40, 'EKS_ROLE_ARN'), (93, 'AWS_DRD_CLOUD_ROLE_ARN'), (16, 'GOOGLE_CHAT_BOT_OAUTH_TOKEN'), (17, 'GOOGLE_CHAT_BOT_SPACES'), (21, 'GRAFANA_HOST'), (22, 'GRAFANA_API_KEY'), (24, 'CLICKHOUSE_INTERFACE'), (25, 'CLICKHOUSE_HOST'), (26, 'CLICKHOUSE_PORT'), (27, 'CLICKHOUSE_USER'), (28, 'CLICKHOUSE_PASSWORD'), (29, 'GCM_PROJECT_ID'), (30, 'GCM_PRIVATE_KEY'), (31, 'GCM_CLIENT_EMAIL'), (32, 'GCM_TOKEN_URI'), (33, 'POSTGRES_HOST'), (34, 'POSTGRES_USER'), (35, 'POSTGRES_PASSWORD'), (36, 'POSTGRES_PORT'), (37, 'POSTGRES_DATABASE'), (38, 'POSTGRES_OPTIONS'), (39, 'SQL_DATABASE_CONNECTION_STRING_URI'), (41, 'PAGER_DUTY_API_KEY'), (63, 'PAGER_DUTY_CONFIGURED_EMAIL'), (42, 'OPS_GENIE_API_KEY'), (43, 'AGENT_PROXY_HOST'), (44, 'AGENT_PROXY_API_KEY'), (45, 'GITHUB_TOKEN'), (47, 'OPEN_AI_API_KEY'), (49, 'REMOTE_SERVER_PEM'), (50, 'REMOTE_SERVER_USER'), (51, 'REMOTE_SERVER_HOST'), (52, 'REMOTE_SERVER_PASSWORD'), (53, 'MIMIR_HOST'), (54, 'X_SCOPE_ORG_ID'), (55, 'SSL_VERIFY'), (56, 'AZURE_SUBSCRIPTION_ID'), (57, 'AZURE_TENANT_ID'), (58, 'AZURE_CLIENT_ID'), (59, 'AZURE_CLIENT_SECRET'), (60, 'GKE_PROJECT_ID'), (61, 'GKE_SERVICE_ACCOUNT_JSON'), (62, 'MS_TEAMS_CONNECTOR_WEBHOOK_URL'), (64, 'ELASTIC_SEARCH_PROTOCOL'), (65, 'ELASTIC_SEARCH_HOST'), (66, 'ELASTIC_SEARCH_PORT'), (67, 'ELASTIC_SEARCH_API_KEY_ID'), (68, 'ELASTIC_SEARCH_API_KEY'), (69, 'GRAFANA_LOKI_PROTOCOL'), (70, 'GRAFANA_LOKI_HOST'), (71, 'GRAFANA_LOKI_PORT'), (72, 'KUBERNETES_CLUSTER_NAME'), (73, 'KUBERNETES_CLUSTER_API_SERVER'), (74, 'KUBERNETES_CLUSTER_TOKEN'), (75, 'KUBERNETES_CLUSTER_CERTIFICATE_AUTHORITY_DATA'), (76, 'KUBERNETES_CLUSTER_CERTIFICATE_AUTHORITY_PATH'), (77, 'SMTP_HOST'), (78, 'SMTP_PORT'), (79, 'SMTP_USER'), (80, 'SMTP_PASSWORD'), (81, 'BIG_QUERY_PROJECT_ID'), (82, 'BIG_QUERY_SERVICE_ACCOUNT_JSON'), (83, 'ZENDUTY_API_KEY'), (84, 'ROOTLY_API_KEY'), (85, 'JIRA_CLOUD_API_KEY'), (86, 'ASANA_ACCESS_TOKEN'), (87, 'CONFLUENCE_CLOUD_API_KEY'), (88, 'NOTION_API_KEY'), (89, 'DRD_PROXY_AGENT_HOST'), (90, 'DRD_PROXY_AGENT_API_TOKEN'), (91, 'DRD_PROXY_AGENT_API_KEY'), (92, 'MONGODB_CONNECTION_STRING'), (94, 'OPEN_SEARCH_PROTOCOL'), (95, 'OPEN_SEARCH_HOST'), (96, 'OPEN_SEARCH_PORT'), (97, 'OPEN_SEARCH_USERNAME'), (98, 'OPEN_SEARCH_PASSWORD'), (99, 'LINEAR_API_KEY'), (100, 'JENKINS_URL'), (101, 'JENKINS_USERNAME'), (102, 'JENKINS_API_TOKEN'), (103, 'GITHUB_ACTIONS_TOKEN'), (110, 'JIRA_EMAIL'), (109, 'JIRA_DOMAIN'), (106, 'ARGOCD_SERVER'), (107, 'ARGOCD_TOKEN'), (111, 'REDIS_HOST'), (112, 'REDIS_PORT'), (113, 'REDIS_PASSWORD'), (114, 'REDIS_DB'), (115, 'REDIS_SSL_ENABLED')], default=0, null=True),
+        ),
+        migrations.AlterField(
+            model_name='connectormetadatamodelstore',
+            name='connector_type',
+            field=models.IntegerField(choices=[(0, 'UNKNOWN'), (1, 'SENTRY'), (2, 'SEGMENT'), (3, 'ELASTIC_SEARCH'), (4, 'AMPLITUDE'), (5, 'AWS_KINESIS'), (6, 'CLOUDWATCH'), (7, 'CLEVERTAP'), (8, 'RUDDERSTACK'), (9, 'MOENGAGE'), (10, 'CRIBL'), (11, 'KAFKA'), (12, 'DATADOG'), (13, 'FILEBEAT'), (14, 'LOGSTASH'), (15, 'FLUENTD'), (16, 'FLUENTBIT'), (17, 'PAGER_DUTY'), (18, 'NEW_RELIC'), (19, 'SLACK'), (20, 'HONEYBADGER'), (21, 'GOOGLE_CHAT'), (22, 'DATADOG_OAUTH'), (23, 'GCM'), (24, 'PROMETHEUS'), (25, 'ELASTIC_APM'), (26, 'VICTORIA_METRICS'), (27, 'SLACK_CONNECT'), (28, 'GRAFANA'), (29, 'CLICKHOUSE'), (30, 'DOCUMENTATION'), (31, 'POSTGRES'), (32, 'OPS_GENIE'), (33, 'EKS'), (34, 'AGENT_PROXY'), (35, 'GRAFANA_VPC'), (36, 'GITHUB'), (37, 'SQL_DATABASE_CONNECTION'), (38, 'OPEN_AI'), (39, 'REMOTE_SERVER'), (40, 'API'), (41, 'BASH'), (42, 'AZURE'), (43, 'GRAFANA_MIMIR'), (44, 'GKE'), (45, 'MS_TEAMS'), (46, 'GRAFANA_LOKI'), (47, 'KUBERNETES'), (48, 'SMTP'), (49, 'BIG_QUERY'), (50, 'ZENDUTY'), (51, 'ROOTLY'), (52, 'JIRA_CLOUD'), (53, 'ASANA'), (54, 'CONFLUENCE_CLOUD'), (55, 'CONFLUENCE_SELF_HOSTED'), (56, 'GOOGLE_DRIVE'), (57, 'NOTION'), (58, 'DRD_PROXY_AGENT'), (59, 'MONGODB'), (60, 'OPEN_SEARCH'), (61, 'LINEAR'), (62, 'JENKINS'), (63, 'GITHUB_ACTIONS'), (65, 'ARGOCD'), (66, 'REDIS')], db_index=True, default=0),
+        ),
+        migrations.AlterField(
+            model_name='connectormetadatamodelstore',
+            name='model_type',
+            field=models.IntegerField(choices=[(0, 'UNKNOWN_MT'), (1, 'NEW_RELIC_POLICY'), (2, 'NEW_RELIC_CONDITION'), (3, 'NEW_RELIC_ENTITY'), (4, 'NEW_RELIC_ENTITY_DASHBOARD'), (5, 'NEW_RELIC_ENTITY_APPLICATION'), (6, 'NEW_RELIC_NRQL'), (101, 'DATADOG_MONITOR'), (102, 'DATADOG_DASHBOARD'), (103, 'DATADOG_LIVE_INTEGRATION_AWS'), (104, 'DATADOG_LIVE_INTEGRATION_AWS_LOG'), (105, 'DATADOG_LIVE_INTEGRATION_AZURE'), (106, 'DATADOG_LIVE_INTEGRATION_CLOUDFLARE'), (107, 'DATADOG_LIVE_INTEGRATION_FASTLY'), (108, 'DATADOG_LIVE_INTEGRATION_GCP'), (109, 'DATADOG_LIVE_INTEGRATION_CONFLUENT'), (110, 'DATADOG_SERVICE'), (111, 'DATADOG_METRIC'), (112, 'DATADOG_QUERY'), (201, 'CLOUDWATCH_METRIC'), (202, 'CLOUDWATCH_LOG_GROUP'), (203, 'CLOUDWATCH_LOG_GROUP_QUERY'), (204, 'CLOUDWATCH_ALARMS'), (205, 'RDS_INSTANCES'), (301, 'GRAFANA_DATASOURCE'), (302, 'GRAFANA_DASHBOARD'), (303, 'GRAFANA_TARGET_METRIC_PROMQL'), (304, 'GRAFANA_PROMETHEUS_DATASOURCE'), (305, 'GRAFANA_ALERT_RULE'), (401, 'CLICKHOUSE_DATABASE'), (501, 'SLACK_CHANNEL'), (601, 'MARKDOWN'), (602, 'IFRAME'), (701, 'POSTGRES_QUERY'), (801, 'EKS_CLUSTER'), (901, 'SQL_DATABASE_CONNECTION_RAW_QUERY'), (1001, 'AZURE_WORKSPACE'), (1100, 'SSH_SERVER'), (1201, 'GRAFANA_MIMIR_PROMQL'), (1301, 'GKE_CLUSTER'), (1401, 'MS_TEAMS_CHANNEL'), (1501, 'PAGERDUTY_INCIDENT'), (1601, 'ELASTIC_SEARCH_INDEX'), (1701, 'GCM_METRIC'), (1801, 'ZENDUTY_INCIDENT'), (1901, 'ROOTLY_INCIDENT'), (2001, 'OPS_GENIE_ESCALATION'), (2002, 'OPS_GENIE_TEAM'), (2101, 'GOOGLE_CHAT_SPACE'), (2201, 'MONGODB_DATABASE'), (2202, 'MONGODB_COLLECTION'), (2301, 'OPEN_SEARCH_INDEX'), (2401, 'ASANA_PROJECT'), (2701, 'JIRA_PROJECT'), (2702, 'JIRA_USER'), (2801, 'ARGOCD_APPS'), (2901, 'REDIS_CONNECTION')], db_index=True, default=0),
+        ),
+    ]

connectors/models.py

@@ -50,6 +50,7 @@
     Source.BIG_QUERY: 'BIG QUERY',
     Source.JIRA_CLOUD: 'JIRA',
     Source.ARGOCD: 'ARGOCD',
+    Source.REDIS: 'REDIS',
 }
 
 integrations_connector_type_category_map = {
@@ -83,6 +84,7 @@
     Source.POSTGRES: 'Database',
     Source.SQL_DATABASE_CONNECTION: 'Database',
     Source.BIG_QUERY: 'Database',
+    Source.REDIS: 'Database',
     Source.OPEN_AI: 'LLM Tools',
     Source.BASH: 'Remote Server',
     Source.KUBERNETES: 'Cloud',
@@ -343,6 +345,20 @@
             SourceKeyType.ARGOCD_TOKEN,
         ]
     ],
+    Source.REDIS: [
+        # A single full-key set, same as Postgres/Clickhouse. The UI always
+        # submits all five keys (empty string for the ones left blank), and
+        # RedisProcessor.__init__ already treats blank port/password/db/ssl
+        # as "use the default" - so this covers the common case without the
+        # combinatorial subset list validation would otherwise need.
+        [
+            SourceKeyType.REDIS_HOST,
+            SourceKeyType.REDIS_PORT,
+            SourceKeyType.REDIS_PASSWORD,
+            SourceKeyType.REDIS_DB,
+            SourceKeyType.REDIS_SSL_ENABLED,
+        ]
+    ],
 }
 
 integrations_connector_key_display_name_map = {
@@ -426,6 +442,11 @@
     SourceKeyType.JIRA_DOMAIN: 'Domain',
     SourceKeyType.ARGOCD_SERVER: 'ArgoCD Server',
     SourceKeyType.ARGOCD_TOKEN: 'Token',
+    SourceKeyType.REDIS_HOST: 'Host',
+    SourceKeyType.REDIS_PORT: 'Port',
+    SourceKeyType.REDIS_PASSWORD: 'Password',
+    SourceKeyType.REDIS_DB: 'DB Number',
+    SourceKeyType.REDIS_SSL_ENABLED: 'SSL Enabled',
 }
 
 
@@ -574,7 +595,8 @@ def proto(self):
                              SourceKeyType.JIRA_EMAIL,
                              SourceKeyType.JIRA_DOMAIN,
                              SourceKeyType.ARGOCD_SERVER,
-                             SourceKeyType.ARGOCD_TOKEN]:
+                             SourceKeyType.ARGOCD_TOKEN,
+                             SourceKeyType.REDIS_PASSWORD]:
             key_value = '*********' + self.key[-4:]
         return ConnectorKeyProto(key_type=self.key_type,
                                  key=StringValue(value=key_value),

connectors/utils.py

@@ -139,6 +139,18 @@ def generate_credentials_dict(connector_type, connector_keys):
                 credentials_dict['database'] = conn_key.key.value
             elif conn_key.key_type == SourceKeyType.POSTGRES_PORT:
                 credentials_dict['port'] = conn_key.key.value
+    elif connector_type == Source.REDIS:
+        for conn_key in connector_keys:
+            if conn_key.key_type == SourceKeyType.REDIS_HOST:
+                credentials_dict['host'] = conn_key.key.value
+            elif conn_key.key_type == SourceKeyType.REDIS_PORT:
+                credentials_dict['port'] = conn_key.key.value
+            elif conn_key.key_type == SourceKeyType.REDIS_PASSWORD:
+                credentials_dict['password'] = conn_key.key.value
+            elif conn_key.key_type == SourceKeyType.REDIS_DB:
+                credentials_dict['db'] = conn_key.key.value
+            elif conn_key.key_type == SourceKeyType.REDIS_SSL_ENABLED:
+                credentials_dict['ssl_enabled'] = conn_key.key.value
     elif connector_type == Source.SQL_DATABASE_CONNECTION:
         for conn_key in connector_keys:
             if conn_key.key_type == SourceKeyType.SQL_DATABASE_CONNECTION_STRING_URI:

executor/playbook_source_facade.py

@@ -28,6 +28,7 @@
 from executor.source_managers.datadog_source_manager import DatadogSourceManager
 from executor.source_managers.eks_source_manager import EksSourceManager
 from executor.source_managers.postgres_source_manager import PostgresSourceManager
+from executor.source_managers.redis_source_manager import RedisSourceManager
 from executor.source_managers.zenduty_source_manager import ZendutySourceManager
 from executor.source_managers.sql_database_connection_source_manager import SqlDatabaseConnectionSourceManager
 from executor.source_managers.rootly_source_manager import RootlySourceManager
@@ -134,6 +135,7 @@ def test_source_connection(self, source_connection: ConnectorProto):
 playbook_source_facade.register(Source.GRAFANA_LOKI, GrafanaLokiSourceManager())
 
 playbook_source_facade.register(Source.POSTGRES, PostgresSourceManager())
+playbook_source_facade.register(Source.REDIS, RedisSourceManager())
 playbook_source_facade.register(Source.CLICKHOUSE, ClickhouseSourceManager())
 playbook_source_facade.register(Source.SQL_DATABASE_CONNECTION, SqlDatabaseConnectionSourceManager())
 playbook_source_facade.register(Source.ELASTIC_SEARCH, ElasticSearchSourceManager())