StreamField 데이터 마이그레이션 참조¶

MigrateStreamData¶

class MigrateStreamData(RunPython)

StreamField 데이터 마이그레이션 작업을 위한 RunPython의 서브클래스

def __init__(app_name,
             model_name,
             field_name,
             operations_and_block_paths,
             revisions_from=None,
             chunk_size=1024,
             **kwargs)

MigrateStreamData(
    app_name="blog",
    model_name="BlogPage",
    field_name="content",
    operations_and_block_paths=[
        (RenameStreamChildrenOperation(old_name="field1", new_name="block1"), ""),
    ],
    revisions_from=datetime.datetime(2022, 7, 25)
)

RenameStreamChildrenOperation¶

class RenameStreamChildrenOperation(BaseBlockOperation)

주어진 유형의 모든 StreamBlock 자식 이름 변경

참고:

이 작업을 사용할 때 block_path_str 은 이름이 변경될 블록이 아닌 이름이 변경될 블록을 포함하는 부모 StreamBlock 을 가리켜야 합니다.

속성:

• old_name str - 이름이 변경될 자식 블록 유형의 이름

• new_name str - 변경할 새 이름

RenameStructChildrenOperation¶

class RenameStructChildrenOperation(BaseBlockOperation)

주어진 유형의 모든 StructBlock 자식 이름 변경

참고:

이 작업을 사용할 때 block_path_str 은 이름이 변경될 블록이 아닌 이름이 변경될 블록을 포함하는 부모 StructBlock 을 가리켜야 합니다.

속성:

• old_name str - 이름이 변경될 자식 블록 유형의 이름

• new_name str - 변경할 새 이름

RemoveStreamChildrenOperation¶

class RemoveStreamChildrenOperation(BaseBlockOperation)

주어진 유형의 모든 StreamBlock 자식 제거

참고:

이 작업을 사용할 때 block_path_str 은 제거될 블록이 아닌 제거될 블록을 포함하는 부모 StreamBlock 을 가리켜야 합니다.

속성:

• name str - 제거될 자식 블록 유형의 이름

RemoveStructChildrenOperation¶

class RemoveStructChildrenOperation(BaseBlockOperation)

주어진 유형의 모든 StructBlock 자식 제거

참고:

이 작업을 사용할 때 block_path_str 은 제거될 블록이 아닌 제거될 블록을 포함하는 부모 StructBlock 을 가리켜야 합니다.

속성:

• name str - 제거될 자식 블록 유형의 이름

StreamChildrenToListBlockOperation¶

class StreamChildrenToListBlockOperation(BaseBlockOperation)

주어진 유형의 StreamBlock 자식을 새 ListBlock 으로 결합

참고:

이 작업을 사용할 때 block_path_str 은 자식 블록 자체가 아닌 결합될 블록을 포함하는 부모 StreamBlock 을 가리켜야 합니다.

속성:

• block_name str - 결합될 자식 블록 유형의 이름

• list_block_name str - 새 ListBlock 유형의 이름

StreamChildrenToStreamBlockOperation¶

class StreamChildrenToStreamBlockOperation(BaseBlockOperation)

주어진 유형의 StreamBlock 자식을 새 StreamBlock 으로 결합

참고:

이 작업을 사용할 때 block_path_str 은 자식 블록 자체가 아닌 결합될 블록을 포함하는 부모 StreamBlock 을 가리켜야 합니다.

속성:

• block_names [str] - 결합될 자식 블록 유형의 이름

• stream_block_name str - 새 StreamBlock 유형의 이름

AlterBlockValueOperation¶

class AlterBlockValueOperation(BaseBlockOperation)

각 블록의 값을 주어진 값으로 변경

속성:

• new_value: 변경할 새 값

StreamChildrenToStructBlockOperation¶

class StreamChildrenToStructBlockOperation(BaseBlockOperation)

주어진 유형의 각 StreamBlock 자식을 새 StructBlock 안으로 이동

주어진 유형의 각 자식 블록에 대해 부모 StreamBlock 의 자식으로 새 StructBlock 이 생성되고, 해당 자식 블록은 부모 StreamBlock의 자식에서 새 StructBlock 안으로 이동됩니다.

예시:

다음 StreamField 정의를 고려해 봅시다.

mystream = StreamField([("char1", CharBlock()), ...], ...)

그러면 스트림 데이터는 다음과 같습니다.

[
    ...,
    { "type": "char1", "value": "Value1", ... },
    { "type": "char1", "value": "Value2", ... },
    ...
]

그리고 다음과 같이 작업을 정의하면:

StreamChildrenToStructBlockOperation("char1", "struct1")

변경될 스트림 데이터는 다음과 같습니다.

[
    ...,
    { "type": "struct1", "value": { "char1": "Value1" } },
    { "type": "struct1", "value": { "char1": "Value2" } },
    ...,
]

참고:

• 이 작업을 사용할 때 block_path_str 은 자식 블록 자체가 아닌 결합될 블록을 포함하는 부모 StreamBlock 을 가리켜야 합니다.

• 새 블록은 이전 블록과 구조적으로 다르므로 블록 ID는 여기에 보존되지 않습니다.

속성:

• block_names str - 결합될 자식 블록 유형의 이름

• struct_block_name str - 새 StructBlock 유형의 이름

InvalidBlockDefError¶

class InvalidBlockDefError(Exception)

유효하지 않은 블록 정의에 대한 예외

def map_block_value(block_value, block_def, block_path, operation, **kwargs)

def map_struct_block_value(struct_block_value, block_def, block_path,
                           **kwargs)

def map_list_block_value(list_block_value, block_def, block_path, **kwargs)

def apply_changes_to_raw_data(raw_data, block_path_str, operation, streamfield,
                              **kwargs)