Kopiowanie danych z redshift S3 do AWS za pomocą pythona i psycopg2
Mam problemy z wykonaniem polecenia copy, aby załadować dane z S3 do Redshift Amazon z Pythona.
Mam następujące polecenie kopiowania:
copy moves from 's3://<my_bucket_name>/moves_data/2013-03-24/18/moves'
credentials 'aws_access_key_id=<key_id>;aws_secret_access_key=<key_secret>'
removequotes
delimiter ',';
Kiedy wykonuję to polecenie za pomocą SQL Workbench / j, wszystko działa zgodnie z oczekiwaniami, jednak gdy próbuję to wykonać za pomocą pythona i psycopg2, polecenie to jest OK, ale żadne dane nie są ładowane i nie jest zgłaszany błąd.
wypróbowałem następujące dwie opcje (załóżmy, że połączenie psycopg2 jest OK, ponieważ jest):
cursor.execute(copy_command)
cursor.copy_expert(copy_command, sys.stdout)
oba przekazują bez ostrzeżenia, ale dane nie są ładowane
Pomysły?
Dzięki