Merge remote-tracking branch 'origin/api-v1.8.2' into api-v1.9.5
This commit is contained in:
commit
42ecb29e6a
10 changed files with 19 additions and 27 deletions
|
|
@ -196,7 +196,7 @@ def process():
|
|||
cur.execute(query)
|
||||
result = cur.fetchone()
|
||||
if result["valid"]:
|
||||
logging.info("Valid alert, notifying users, alertId:{alert['alertId']} name: {alert['name']}")
|
||||
logging.info(f"Valid alert, notifying users, alertId:{alert['alertId']} name: {alert['name']}")
|
||||
notifications.append(generate_notification(alert, result))
|
||||
except Exception as e:
|
||||
logging.error(f"!!!Error while running alert query for alertId:{alert['alertId']} name: {alert['name']}")
|
||||
|
|
|
|||
|
|
@ -99,7 +99,8 @@ class Slack:
|
|||
url=integration["endpoint"],
|
||||
json={"attachments": attachments[i:i + 100]})
|
||||
if r.status_code != 200:
|
||||
print("!!!! something went wrong")
|
||||
print("!!!! something went wrong while sending to:")
|
||||
print(integration)
|
||||
print(r)
|
||||
print(r.text)
|
||||
|
||||
|
|
|
|||
|
|
@ -42,8 +42,8 @@ sourcemaps_reader=http://sourcemaps-reader-openreplay.app.svc.cluster.local:9000
|
|||
STAGE=default-foss
|
||||
version_number=1.4.0
|
||||
FS_DIR=/mnt/efs
|
||||
EFS_SESSION_MOB_PATTERN=%(sessionId)s/dom.mob
|
||||
EFS_DEVTOOLS_MOB_PATTERN=%(sessionId)s/devtools.mob
|
||||
EFS_SESSION_MOB_PATTERN=%(sessionId)s
|
||||
EFS_DEVTOOLS_MOB_PATTERN=%(sessionId)sdevtools
|
||||
SESSION_MOB_PATTERN_S=%(sessionId)s/dom.mobs
|
||||
SESSION_MOB_PATTERN_E=%(sessionId)s/dom.mobe
|
||||
DEVTOOLS_MOB_PATTERN=%(sessionId)s/devtools.mobs
|
||||
|
|
|
|||
|
|
@ -201,7 +201,7 @@ def process():
|
|||
cur.execute(query)
|
||||
result = cur.fetchone()
|
||||
if result["valid"]:
|
||||
logging.info("Valid alert, notifying users, alertId:{alert['alertId']} name: {alert['name']}")
|
||||
logging.info(f"Valid alert, notifying users, alertId:{alert['alertId']} name: {alert['name']}")
|
||||
notifications.append(generate_notification(alert, result))
|
||||
except Exception as e:
|
||||
logging.error(f"!!!Error while running alert query for alertId:{alert['alertId']} name: {alert['name']}")
|
||||
|
|
|
|||
|
|
@ -294,6 +294,7 @@ def search_sessions(data: schemas.SessionsSearchPayloadSchema, project_id, user_
|
|||
sessions = cur.execute(main_query)
|
||||
except Exception as err:
|
||||
print("--------- SESSIONS-CH SEARCH QUERY EXCEPTION -----------")
|
||||
print(main_query)
|
||||
print("--------- PAYLOAD -----------")
|
||||
print(data.json())
|
||||
print("--------------------")
|
||||
|
|
|
|||
|
|
@ -62,8 +62,8 @@ EXP_ALERTS=false
|
|||
EXP_FUNNELS=false
|
||||
EXP_RESOURCES=true
|
||||
TRACE_PERIOD=300
|
||||
EFS_SESSION_MOB_PATTERN=%(sessionId)s/dom.mob
|
||||
EFS_DEVTOOLS_MOB_PATTERN=%(sessionId)s/devtools.mob
|
||||
EFS_SESSION_MOB_PATTERN=%(sessionId)s
|
||||
EFS_DEVTOOLS_MOB_PATTERN=%(sessionId)sdevtools
|
||||
SESSION_MOB_PATTERN_S=%(sessionId)s/dom.mobs
|
||||
SESSION_MOB_PATTERN_E=%(sessionId)s/dom.mobe
|
||||
DEVTOOLS_MOB_PATTERN=%(sessionId)s/devtools.mobs
|
||||
|
|
|
|||
|
|
@ -70,4 +70,8 @@ WHERE deleted_at IS NOT NULL;
|
|||
UPDATE roles
|
||||
SET permissions=array_remove(permissions, 'ERRORS');
|
||||
|
||||
DROP INDEX IF EXISTS events_common.requests_url_idx;
|
||||
DROP INDEX IF EXISTS events_common.requests_url_gin_idx;
|
||||
DROP INDEX IF EXISTS events_common.requests_url_gin_idx2;
|
||||
|
||||
COMMIT;
|
||||
|
|
@ -1222,19 +1222,9 @@ $$
|
|||
query text NULL,
|
||||
PRIMARY KEY (session_id, timestamp, seq_index)
|
||||
);
|
||||
CREATE INDEX IF NOT EXISTS requests_url_idx ON events_common.requests (url);
|
||||
|
||||
CREATE INDEX IF NOT EXISTS requests_duration_idx ON events_common.requests (duration);
|
||||
CREATE INDEX IF NOT EXISTS requests_url_gin_idx ON events_common.requests USING GIN (url gin_trgm_ops);
|
||||
CREATE INDEX IF NOT EXISTS requests_timestamp_idx ON events_common.requests (timestamp);
|
||||
CREATE INDEX IF NOT EXISTS requests_url_gin_idx2 ON events_common.requests USING GIN (RIGHT(url,
|
||||
length(url) -
|
||||
(CASE
|
||||
WHEN url LIKE 'http://%'
|
||||
THEN 7
|
||||
WHEN url LIKE 'https://%'
|
||||
THEN 8
|
||||
ELSE 0 END))
|
||||
gin_trgm_ops);
|
||||
CREATE INDEX IF NOT EXISTS requests_timestamp_session_id_failed_idx ON events_common.requests (timestamp, session_id) WHERE success = FALSE;
|
||||
CREATE INDEX IF NOT EXISTS requests_request_body_nn_gin_idx ON events_common.requests USING GIN (request_body gin_trgm_ops) WHERE request_body IS NOT NULL;
|
||||
CREATE INDEX IF NOT EXISTS requests_response_body_nn_gin_idx ON events_common.requests USING GIN (response_body gin_trgm_ops) WHERE response_body IS NOT NULL;
|
||||
|
|
|
|||
|
|
@ -60,4 +60,8 @@ BEGIN
|
|||
END;
|
||||
$$ LANGUAGE plpgsql;
|
||||
|
||||
DROP INDEX IF EXISTS events_common.requests_url_idx;
|
||||
DROP INDEX IF EXISTS events_common.requests_url_gin_idx;
|
||||
DROP INDEX IF EXISTS events_common.requests_url_gin_idx2;
|
||||
|
||||
COMMIT;
|
||||
|
|
@ -596,17 +596,9 @@ $$
|
|||
query text NULL,
|
||||
PRIMARY KEY (session_id, timestamp, seq_index)
|
||||
);
|
||||
CREATE INDEX requests_url_idx ON events_common.requests (url);
|
||||
|
||||
CREATE INDEX requests_duration_idx ON events_common.requests (duration);
|
||||
CREATE INDEX requests_url_gin_idx ON events_common.requests USING GIN (url gin_trgm_ops);
|
||||
CREATE INDEX requests_timestamp_idx ON events_common.requests (timestamp);
|
||||
CREATE INDEX requests_url_gin_idx2 ON events_common.requests USING GIN (RIGHT(url, length(url) - (CASE
|
||||
WHEN url LIKE 'http://%'
|
||||
THEN 7
|
||||
WHEN url LIKE 'https://%'
|
||||
THEN 8
|
||||
ELSE 0 END))
|
||||
gin_trgm_ops);
|
||||
CREATE INDEX requests_timestamp_session_id_failed_idx ON events_common.requests (timestamp, session_id) WHERE success = FALSE;
|
||||
CREATE INDEX requests_request_body_nn_gin_idx ON events_common.requests USING GIN (request_body gin_trgm_ops) WHERE request_body IS NOT NULL;
|
||||
CREATE INDEX requests_response_body_nn_gin_idx ON events_common.requests USING GIN (response_body gin_trgm_ops) WHERE response_body IS NOT NULL;
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue