在Beam中使用PTransform來轉換數據，首先需要定義一個PTransform對象，然后通過apply()方法將其應用到數據集上。以下是一個簡單的示例代碼：
from apache_beam import Pipeline, ParDo, DoFn
# 定義一個PTransform對象來將數據集中的每個元素轉換為大寫字母
class ToUpperCase(DoFn):
def process(self, element):
yield element.upper()
# 創建一個Beam Pipeline
pipeline = Pipeline()
# 創建一個PCollection對象，包含要轉換的數據
data = pipeline | 'Create data' >> beam.Create(['hello', 'world'])
# 應用PTransform對象來轉換數據
result = data | 'Convert to uppercase' >> ParDo(ToUpperCase())
# 運行Pipeline
result | 'Print result' >> ParDo(lambda x: print(x))
pipeline.run()
在這個示例中，我們定義了一個名為ToUpperCase的PTransform對象，其process方法將數據集中的每個元素轉換為大寫字母。然后在Pipeline中創建了一個PCollection對象data，包含要轉換的數據。最后，我們將ToUpperCase對象應用到數據集上，并運行Pipeline來執行轉換操作。
