Method test_anonymous_read_write

blackbox/test_s3.py:236–300

(self)

                c.execute('DROP TABLE r1')

    def test_anonymous_read_write(self):
        client = Minio(endpoint='127.0.0.1:9000',
                       access_key = MinioServer.MINIO_ACCESS_KEY,
                       secret_key = MinioServer.MINIO_SECRET_KEY,
                       region = "myRegion",
                       secure = False)

        with MinioServer() as minio:
            t = threading.Thread(target=minio.run)
            t.daemon = True
            t.start()
            wait_until(lambda: _is_up('127.0.0.1', 9000))

            client.make_bucket(bucket_name="my.bucket")

            # https://docs.min.io/docs/python-client-api-reference.html#set_bucket_policy
            # Example anonymous read-write bucket policy.
            policy = {
                "Version": "2012-10-17",
                "Statement": [
                    {
                        "Effect": "Allow",
                        "Principal": {"AWS": "*"},
                        "Action": [
                            "s3:GetBucketLocation",
                            "s3:ListBucket",
                            "s3:ListBucketMultipartUploads",
                        ],
                        "Resource": "arn:aws:s3:::my.bucket",
                    },
                    {
                        "Effect": "Allow",
                        "Principal": {"AWS": "*"},
                        "Action": [
                            "s3:GetObject",
                            "s3:PutObject",
                            "s3:DeleteObject",
                            "s3:ListMultipartUploadParts",
                            "s3:AbortMultipartUpload",
                        ],
                        "Resource": "arn:aws:s3:::my.bucket/*",
                    },
                ],
            }
            client.set_bucket_policy(bucket_name="my.bucket", policy=json.dumps(policy))

            with connect(crate_node.http_url) as conn:
                c = conn.cursor()
                c.execute('CREATE TABLE t1 (x int)')
                c.execute('INSERT INTO t1 (x) VALUES (1), (2), (3)')
                c.execute('REFRESH TABLE t1')

                c.execute("""
                    COPY t1 TO DIRECTORY 's3://127.0.0.1:9000/my.bucket/' WITH (protocol = 'http')
                """)
                c.execute("""
                    COPY t1 FROM 's3://127.0.0.1:9000/my.bucket/*' WITH (protocol = 'http')
                """)