mirror of
https://github.com/ceph/s3-tests.git
synced 2024-11-21 11:51:06 +00:00
add test test_lifecycle_expiration_newer_noncurrent()
This verifies the new NewerNoncurrentVersions lifecycle filter operator. Signed-off-by: Matt Benjamin <mbenjamin@redhat.com>
This commit is contained in:
parent
ade849b90f
commit
d48530a294
1 changed files with 57 additions and 0 deletions
|
@ -8433,6 +8433,63 @@ def test_lifecycle_expiration_noncur_tags1():
|
|||
# at T+60, only the current object version should exist
|
||||
assert num_objs == 1
|
||||
|
||||
def wait_interval_list_object_versions(client, bucket_name, secs):
|
||||
time.sleep(secs)
|
||||
try:
|
||||
response = client.list_object_versions(Bucket=bucket_name)
|
||||
objs_list = response['Versions']
|
||||
except:
|
||||
objs_list = []
|
||||
return len(objs_list)
|
||||
|
||||
@pytest.mark.lifecycle
|
||||
@pytest.mark.lifecycle_expiration
|
||||
@pytest.mark.fails_on_aws
|
||||
@pytest.mark.fails_on_dbstore
|
||||
def test_lifecycle_expiration_newer_noncurrent():
|
||||
bucket_name = get_new_bucket()
|
||||
client = get_client()
|
||||
|
||||
check_configure_versioning_retry(bucket_name, "Enabled", "Enabled")
|
||||
|
||||
# create 10 object versions (9 noncurrent)
|
||||
key = "myobject_"
|
||||
|
||||
for ix in range(10):
|
||||
body = "%s v%d" % (key, ix)
|
||||
response = client.put_object(Bucket=bucket_name, Key=key, Body=body)
|
||||
assert response['ResponseMetadata']['HTTPStatusCode'] == 200
|
||||
|
||||
# add a lifecycle rule which sets newer-noncurrent-versions to 5
|
||||
days = 1
|
||||
lifecycle_config = {
|
||||
'Rules': [
|
||||
{
|
||||
'NoncurrentVersionExpiration': {
|
||||
'NoncurrentDays': days,
|
||||
'NewerNoncurrentVersions': 5,
|
||||
},
|
||||
'ID': 'newer_noncurrent1',
|
||||
'Filter': {
|
||||
'Prefix': '',
|
||||
},
|
||||
'Status': 'Enabled',
|
||||
},
|
||||
]
|
||||
}
|
||||
|
||||
response = client.put_bucket_lifecycle_configuration(
|
||||
Bucket=bucket_name, LifecycleConfiguration=lifecycle_config)
|
||||
assert response['ResponseMetadata']['HTTPStatusCode'] == 200
|
||||
|
||||
lc_interval = get_lc_debug_interval()
|
||||
|
||||
num_objs = wait_interval_list_object_versions(
|
||||
client, bucket_name, 2*lc_interval)
|
||||
|
||||
# at T+20, 6 objects should exist (1 current and (9 - 5) noncurrent)
|
||||
assert num_objs == 6
|
||||
|
||||
@pytest.mark.lifecycle
|
||||
def test_lifecycle_id_too_long():
|
||||
bucket_name = get_new_bucket()
|
||||
|
|
Loading…
Reference in a new issue