Ignacio Alasia
03/23/2022, 6:07 PM--CREATE USER
CREATE USER nacho PASSWORD 'MyPassword';
--Grant to user
GRANT USAGE ON SCHEMA public TO nacho;
--More grants
GRANT SELECT ON ALL TABLES IN SCHEMA public TO nacho;
-- Allow user to see tables created in the future
ALTER DEFAULT PRIVILEGES IN public SCHEMA GRANT SELECT ON TABLES TO nacho;
--Replication slots
--This Airbyte user for your instance needs to be granted REPLICATION and LOGIN permissions.
--You can create a role with
CREATE ROLE rsrole REPLICATION LOGIN;
--And grant that role to the user
GRANT rsrole TO nacho;
--CREATE REPLICATION SLOT
SELECT pg_create_logical_replication_slot('rs_nacho', 'pgoutput');
--DROP REPLICATION SLOT
--select pg_drop_replication_slot('rs_nacho');
--ACTIVATE RS
SELECT redo_lsn, slot_name, restart_lsn,
round((redo_lsn-restart_lsn) / 1024 / 1024 / 1024, 2) AS GB_behind, database, active
FROM pg_control_checkpoint(), pg_replication_slots;
--CREATE RANDOM TABLE
CREATE TABLE stage(
IDESTADE SERIAL PRIMARY KEY,
name VARCHAR(45) NOT NULL,
address VARCHAR(45) NOT NULL
);
--inserts
INSERT INTO stadium (name, address) VALUES ('pepito','bsas');
INSERT INTO stadium (name, address) VALUES ('rolinga','bsas');
--
ALTER TABLE stage REPLICA IDENTITY DEFAULT;
--create Publication
CREATE PUBLICATION airbyte_test FOR TABLE stage;
I managed to make the connection between source and destination successfully, it creates the normalization table but when it comes to taking the information it throws me the following error:
"2022-03-23 17:26:41 normalization > 17:26:41 Done. PASS=1 WARN=0 ERROR=0 SKIP=0 TOTAL=1
2022-03-23 17:26:41 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 23 seconds.
2022-03-23 17:26:41 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-03-23 17:26:41 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporary heartbeat...
2022-03-23 17:26:41 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed.errors: $.plugin: is not defined in the schema and the schema does not allow additional properties, $.publication: is not defined in the schema and the schema does not allow additional properties, $.replication_slot: is not defined in the schema and the schema does not allow additional properties, $.method: does not have a value in the enumeration [Standard], $.method: must be a constant value Standard
2022-03-23 17:26:41 INFO i.a.v.j.JsonSchemaValidator(test):56 - JSON schema validation failed.
errors: $.method: does not have a value in the enumeration [Standard]"
Could someone shed a little light here?Marcos Marx (Airbyte)
03/23/2022, 10:20 PMIgnacio Alasia
03/23/2022, 11:00 PMMarcos Marx (Airbyte)
03/23/2022, 11:01 PMIgnacio Alasia
03/23/2022, 11:05 PMIgnacio Alasia
03/28/2022, 2:14 PMIgnacio Alasia
04/01/2022, 7:46 PMMijbel Alqattan
04/20/2022, 9:14 AMMijbel Alqattan
04/20/2022, 10:08 AMIgnacio Alasia
04/20/2022, 1:20 PMMijbel Alqattan
04/20/2022, 2:42 PMIgnacio Alasia
04/20/2022, 2:43 PM